我已经创建了这个订阅，它创建了另一个订阅： .filter(interval -> interval > 0) } .takeUntil(this.destroy$)因此，每当interval发生变化，并且大于0时，我就构建另一个订阅读取配置文件
浏览 1提问于2017-06-06得票数 0
回答已采纳
我在学习OnErrorNotImplementedException的时候遇到了RxJava2。我了解到，此异常的发生是由于未对订阅服务器实现错误处理程序。
浏览 0提问于2018-02-28得票数 0
回答已采纳
我正在尝试将这个RxJava1代码转换为RxJava2 return; subscriber.onError(ioe); });问题是，在Rxjava2中，我没有让订阅者向它添加新的订阅。
浏览 2提问于2016-11-01得票数 4
回答已采纳
，提出了一个关于如何观察取消订阅事件的问题，以便您可以在侦听器取消订阅后清理和删除它。但是，在RxJava2中，上述线程不再工作的方法。aEmitter.add(Subscriptions.create(() -> existingEventSource.removeListener(listener)));在RxJava2中解决这个问题的正确方法是什么
浏览 1提问于2017-12-05得票数 0
回答已采纳
我已经使用RxJava2很长时间了。最近，我正在研究RxJava2的源代码，试图理解它，编写我自己的运算符实现。我发现有很多线程安全的代码。但我认为有些是多余的，这增加了学习的难度。根据 2.7，“订阅者必须确保其订阅上的所有调用都发生在同一线程中，或者提供各自的外部同步。”调用者不是有责任确保它的调用是线程安全的吗？
浏览 0提问于2018-07-27得票数 1
在安卓系统中，subscribe()和subscribeWith()在RxJava2中有什么区别？这两个函数都用于订阅一个可观察到的观察者。这两种功能的主要区别是什么？在哪里使用订阅，在哪里使用subscribeWith。如果可能，请提供代码示例。
浏览 5提问于2017-12-23得票数 6
我想运行一个新的线程，当用户点击按钮。在这个线程中，我在"i++“之后调用睡眠(2000)，并在TextView中返回字符串("Text”+ i)。我有一个例子，但它不起作用： Observable.create(new Observable.OnSubscribe<Void>() { public void call(Subscriber<? super Void> subscriber) { i++;
subsc
浏览 17提问于2020-12-02得票数 0
回答已采纳
我在类(A)中创建了一个任务，然后异步调用，然后如果任务完成或取消，传递结果另一个类(B)，在rxJava2中使用，在rxJava2中是非常新的，我可以使用这个逻辑吗?我想做的是 调用异步任务类(B)，运行任务并发出一些结果类(A)，然后在类(B)中订阅任务结果，你有什么想法吗？感谢您的建议
浏览 15提问于2019-01-17得票数 0
回答已采纳
在RxJava1中执行以下操作时，onNext中的异常会重新路由到同一订阅者的onError中： });D/RxJava1: 1 - 1D/RxJava1: 333 - 3据我所知，当在RxJava2Integer test = null;
浏览 7提问于2017-01-25得票数 5
回答已采纳
我们需要一个全局处理程序来处理传递给任何订阅者的rxJava2异常，以便只记录系统任何部分中发生的堆栈跟踪。RxJavaHooks.setOnError(throwable -> Log.w(TAG, "rx error", throwable));我真的不想把记录器附加到系统中每一个可以观察到的地方
Upd:也许你对android系统有一些建议。
浏览 4提问于2017-08-31得票数 1
回答已采纳
我正在观察一个来自Kotlin类的RxJava2流。Kotlin正在将这些转换为可观测/单/平台类型(例如Observable<Widget!>)的流程。我知道很少有人谈论那个
因此，既然RxJava2不能发出null，那么我能安全地假设任何发出的类型都是不可空的Kotlin类型吗？换句话说，我是否可以依赖RxJava在对象到达订阅服务器之前抛出一个NullPointerException？
浏览 4提问于2019-11-19得票数 0
回答已采纳
当我使用Observable.subscribe()时，通常返回Disposable。所以我不能处置给Observable.subscribe(观察者)。为什么rx和rxjava不同？我在Android Studio中使用compile 'io.reactivex.rxjava2:rxandroid:2.0.1'。
github.com/Reactive
浏览 5提问于2017-06-16得票数 6
2回答
使用Retrofit2 (Ver: 2.3.0)，OkHTTP3 (Ver: 3.9.0)和RxJava2 (Ver: 2.0.0) Observable<ServerResponse如果验证用户，则预期成功响应JSON POJO如果未验证用户，则预期成功响应JSON POJO .subscribeWith(observer);
如果验证了==否，则会抛出
浏览 3提问于2017-09-28得票数 1
1回答
executeAsync(actions);}
我想在RXJava2中做同样的模型。任何帮助都是非常感谢的。
浏览 0提问于2018-09-19得票数 8
1回答
我在阿波罗和Rxjava2中使用订阅，如下所示 Rx2Apollo.from(someApolloCall).subscribeOnschedulerProvider.ui()) // on failure
}) 当网络正常时，一切工作正常，但是当失去连接时，订阅失败
浏览 14提问于2018-12-19得票数 0
2回答
如果观察值完成，我是否仍然必须取消订阅/处置(在RxJava2中)观察值以删除观察值(防止内存泄漏)，或者一旦发生onComplete或onError事件，这是否由RxJava内部处理？
浏览 0提问于2017-01-24得票数 32
回答已采纳
我目前使用RxJava2订阅了一个可流动的方法，假设我有一个我订阅的方法。但一旦我订阅，我将继续从该流动的事件。我将从已确定的项中获取单个更改，例如已确定的项已更改。
如何将单个更改与初始加载区分开来？
浏览 4提问于2018-02-23得票数 1
回答已采纳
如果订阅了可观察到的内容，则一次性存储在CompositeDisposable中，并按预期处理异常。
浏览 5提问于2017-03-23得票数 0
回答已采纳
主分支使用rxjava3，但功能分支使用rxjava2。然而，当我从主分支切换到功能分支时，Android Studio无法识别rxjava2导入。我的gradle构建引用了rxjava2，而不是rxjava3，所以我很困惑为什么它构建得很好，但我说有一堆未解析的符号。我使用的是Android Studio 4.1.1。
浏览 111提问于2021-10-09得票数 1
回答已采纳
1回答
如何让Observable<ArrayList<user>>中的每个用户在订阅之前与其他可观察到的用户进行处理。我在堆栈溢出上搜索了它，并让它了解了flatMapIterable()，但是它仍然不是working.How，我会在Rxjava2中这样做吗？请告诉我谁..。
浏览 0提问于2018-01-30得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号