与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
为什么不在`onComplete`和`onNext`中出现`OnErrorNotImplementedException`？
我在学习RxJava2时遇到OnErrorNotImplementedException。我了解到这种异常的发生是由于没有为订阅者实现错误处理程序。所以，我想为什么不存在......
rxjava2：Flowable.unsafeCreate（）vs Flowable.fromPublisher（）
只要我实现自己的发布者 根据反应规范：Publisher publisher = new MyAwesomelyReactivePublisher <>（）;现在我想把它与...联系起来
我正在学习Android的MVP设计，我是新手，所以需要你宝贵的时间。我去了MVP的基础知识它是如何工作的，现在我卡住了所以需要你的帮助，我必须将数据发布到...
如何将Flowable转换为Single？或者，如果有另一种方法使其在第一个感兴趣的响应之后停止发光。我试过这个，但它似乎不起作用：......
对于我正在使用Android Room为本地持久层和RxJava2构建的应用程序，我遇到了一个令人敬畏的问题我无法解决这个问题。请记住，我是RxJava的新手。 ...
我在下面的行中得到了未知的异常：public class RepoListPresenter实现了IRepoListPresenter，OnRepoInteractorFinishedListener {private IRepoListView view;私人的 ...
我用RxJava 2创建了一个非常简单的例子（我开发的所有内容都是使用RxJava 1），我发现了下一个我完全不理解的行为。我有下一个带有拉链的Observable ......
RxJava相对较新。有以下要求。任何指针都会有所帮助。例如： - 有3个可观察量A，B，C，这样A从数据源发出数据，如DB B＆C，都取决于......的数据
我在just（）运算符中传递两个参数。我的代码片段是：Observable observable = Observable.just（1,2）; observable.subscribeOn（Schedulers.newThread（））...
如果我对如何使用RxJava2缺乏基本的了解，请提前道歉，因为在我看来这应该是非常基础的东西。我用不成功的谷歌绞尽脑汁......
我想将响应延迟最多500毫秒。如果updateData已经说了400毫秒，那么我想延迟100毫秒。以下代码总是我推迟...
如何在基础活动暂停时暂停rxjava Observable.interval
我使用MVVM架构，我的数据层/存储库使用RxJava但查看模型以查看图层正在使用LiveData。在我的视图模型中，我使用rxjava Observable.interval轮询服务器。目前 ...
具有state的Observable.generator，其中新状态是异步更新的
这是一个有点人为的例子，但请耐心等待。假设我有一个方法，例如：Single getValue（int offset）;我想多次打电话给这个，传递一个不同的......
我有一个自定义对象列表（列表 itemsList）。这是我的自定义类：public class Item {private String itemId; private String itemName;初始列表只有......
从CompositeDisposable RXJava - Android获取价值
如何从下面的代码中获取返回值：CompositeDisposable mCompositeDisposable = new CompositeDisposable（）; mCompositeDisposable.add（observableSubject（userName，password）...
我创建了一个对youtube api搜索的请求。发送请求时，必须取消之前的请求，并且不对缓存进行更新。我使用CompositeDisposable添加每个Disposable ......
如何取消订阅RxKotlin / RxJava中的Flowable？
我在这篇文章之后使用带有RxJava / RxKotlin Flowable的Room。我得到它运行，但有问题使用它与ViewPager 3片段。我会稍微告诉你我的代码：我有......
我有应用程序必须发送数据的远程服务：retrofit2中的定义：interface FooRemoteService {@POST（“/ foos”）有趣的postFoos（@Body foos：List ）：可观察
RxJava io.reactivex.exceptions.OnErrorNotImplementedException：必须从片段主机的主线程调用
我对RxJava中的线程处理有点困惑。 @Override protected void onCreate（Bundle savedInstanceState）{super.onCreate（savedInstanceState）;的setContentView（R.layout ....
使用RxJava，我已经习惯了我的存储库返回Observables数据，这些数据会在发生潜在变化时自动更新。我只想在我的主题中找到一个主题就能实现这个目标......