与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
RxJava`Completable.andThen`没有连续执行？
我有一个用例，我在一个Completable中初始化一些全局变量，并在链的下一步（使用andThen运算符）我使用这些变量。以下示例解释了我...
我正在学习RxJava（绝对是新的，很抱歉，如果这个问题太基础了），我在错误处理机制方面遇到了困难（我已经完成了文档，但这对我来说是先进的方法）。 ...
我在申请中使用改装2时遇到了一个问题。 public static Retrofit getClient（Context context）{if（okHttpClient == null）initOkHttp（context）;如果（...
我有一个基于ConnectivityManager.NetworkCallback的网络更改通知程序类，我想在网络可用时更新一些字段;覆盖乐趣onAvailable（网络：网络？）{...
我已经开始在android中再次编程，因为在过去的4年中它已经发生了很大的变化，我有点困惑。我试图从服务器异步加载我的数据...
RxJava flatMapIterable with Single
我正在尝试整理我的代码，而Single对我来说是一个不错的选择，因为我正在做一些只能发出一个结果的东西。因为我正在使用，我遇到了一个问题......
我有一个元素列表，我想从中分别发出其中5个元素，每秒数/毫秒。我觉得这应该工作：Flowable.just（listOf （ “1” ...
Android房间插入与Completable无法正常工作？用@insert注释的方法可以返回void，long？
我正在使用的版本是实现'io.reactivex.rxjava2：rxjava：2.2.4'实现'io.reactivex.rxjava2：rxandroid：2.1.0'实现'com.jakewharton.rxbinding2：rxbinding：2.0.0'。 ..
对于`RxJava`的`share（）`的协同程序有什么选择？
我有一个配置文件，我正在获取它，因此获取标题和查询列表：字符串和基于查询我应该实现不同的请求我的意思是我有request1 for config和...
如何创建Observable并使用Retrofit稍后更新它们RxJava？
基本上我需要创建一个没有初始值的Observable列表。我订阅了Observables列表，并根据所有Observables的回复提供所需的结果。我用 ...
订阅一次Observable并在RxJava中多次使用它的值
我使用flatMap作为指标，然后我应该发出另一个网络请求。可观察 secoondRequest = firstRequest.flatMap（responseBody - > {return ...
Android ViewModel单元测试：RxJava onSuccess给出nullPointerException
我正在尝试对我的viewModel类进行单元测试，但是当我运行测试时，我在一次性OnSuccess方法中得到一个NullPointerException，我不明白为什么。因为这个我测试的方法......
我正在努力实现RxBus。我打算用它在片段/活动/对话框之间移动对象Animal。在上面的代码我尝试将我的对象从Dialog窗口移动到AnswerFragment，谁...
我有2个方法：private void method1（）throws InterruptedException {// SimulateLongOperation Thread.sleep（5000）;的System.out.println（ “hello1”）; } private void method2（）{...
多个Flowable observeOn单个Scheduler，事件的消耗顺序与发出的顺序不同
我正在使用来自不同外部源/订阅包装到不同Flowable的事件。源无关紧要，因为我可以用简单的循环重现问题。我有：不同......
List extends Something>生成而不是List
我有一个服务调用，它返回一个JSON响应，然后通过数据管理器传递，如果服务成功则转换数据，或者如果调用失败则创建一个错误体。 ......
我是RxJava的新手。我正在尝试“监听”列表更改：filteredEvents = eventViewModel.getAllByInterval（dateStart，dateEnd）;一次性使用= filteredEvents.subscribeOn（...
我有一个rxJava2 Observable，我想有条件地订阅它。方案我将进行网络呼叫，只有当设备连接到网络时才会调用subscribe（）。我想做...
假设我有一个公开两个方法的API，每个方法返回一个observable import org.assertj.core.util.VisibleForTesting; import java.util.Random; import java.util.concurrent.TimeUnit;进口io ....
如何创建一个Flowable，在其最后一个订阅者取消其订阅后立即完成
我有一个案例，我需要建立一个由多个元素组成的反应流，可以用两种不同的方式完成。我看到的链条看起来有点像这样：在...的顶部