RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我在Android应用中使用RxJava2。我想知道是否可以使用类似flappMap的方法来处理错误。所以，我想知道的是：是否有任何方法返回另一个...
使用Android Clean Architechture处理来自API的错误和成功响应
我正在尝试在我的应用程序中实现Clean Architecture。我的API在成功和失败情况下发送响应，例如：{“ data”：[]，“ statusCode”：200，“ statusMessage”：“ success”，“ success”：true ...
没有人知道如何执行以下操作：必须解析元素的内容，并且必须通过进行并行查询对子元素进行分组。您应该前进到列表中的下一个项目...
为什么要在与PriceResource Publisher的多个连接中，只有一个获得流？
似乎只有一个http客户端获取数据流，而其他HTTP客户端没有。发布者是热门数据，是否应该向所有订阅者广播，这是真的吗？请在...
AsyncSubject可以处理RxJava中的SingleLiveEvent情况吗？
问题一次性事件的反应式编程模式的问题在于，可能在最初的一次性事件发生后将它们重新发送给订户。对于LiveData，...
RxJava，等待多个Observable在同一时间提供所需的结果
我有多个Observable 从“警报传感器”传递数据。他们只提供价值变化。如何等待直到所有这些都切换为false，这才表明没有...
我正在设计一个允许检查Android设备上的Internet连接的功能。我决定使用被动方法来实现它。该函数非常好用，非常简单：...
（（Scala + RxJava3）Flowables.orderedMerge NoSuchMethodError
[在Ammonite中，我执行以下代码...试图进行两个Flowable的orderedMerge，导入$ ivy。{`io.circe :: circe-generic：0.13.0`，`io.circe :: circe-解析器：0.13.0` ...
我正在使用MVVM体系结构，所以基本上这就是我的流程-获取存储库实例并将结果返回给Activity-public MainViewModel（）{filmsRepository = MoviesRepository ....
你好，我有类似的东西：Observable.fromIterable（0..4）.map {if（it == 3）throw Exception（）else} .subscribe {println（it）}我希望它返回除以下以外的所有值一个（它== ...
使用rx-java程序包，如何尾部文件？代码：包尾；导入java.io.BufferedReader;导入java.io.IOException;导入java.io.InputStream;导入java.io.InputStreamReader;导入...
带有和不带有ObserveOn的RxJava PublishSubject
我有三个整数观察者，如下所示：第一观察者：私有观察者 getFirstObserver（）{返回新的观察者 （）{@Override ...
公共类MainActivity1扩展了AppCompatActivity {private String LOG_TAG =“ MY_LOG”;私人CompositeDisposable CompositeDisposable = new CompositeDisposable（）; @Override ...
RxJava-使用Single.Error / Observable.error与引发异常
我最近开始在我的一个项目中使用RxJava2，目前正在致力于在其中实现错误处理。我在下面编写了一个模拟类，最初在其中抛出了...
我有两个可观察对象，一个可以非常快速地发出事件。我需要同步它们，例如当observable1发出时，我从observable2中获取最后一个，并做一些事情。我该怎么办：Observable ] >>>> 我想应该使用.combineLatest。它将是： mStateSubscription = Observable.combineLatest(pairingState, added, (state, user) -> true) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .delay(MESSAGE_SEND_DELAY, TimeUnit.MILLISECONDS) .subscribe(event -> { //do some stuff }); 虽然可能需要combineLatest，但您也应该查看withLatestFrom。 [withLatestFrom：当可观察到的1发出时，使用可观察到的2中的最新值。当可观察到的2发出时，使用可观察到的1中的最新值。 [combineLatest：当观察到的1发出时，使用观察到的2中的最新值。当观察到的2发出时，仅更新内部状态。
我有以下问题：我有一个Single，它返回一个对象列表，在每个对象内部，还有一个字段也是Single，并返回一个项目列表（这是我需要的），但是...
我想将company和workFor变量合并为一个流，但是我不知道如何。我尝试使用switchMap，zip，merge和concatMapIterable，但没有任何效果。还是我做错了。。我的...
我有一个具有多个订阅者的发布主题：这是课程：类Real {私有val发布者：PublishSubject = PublishSubject.create（）fun doPublish（）{...
最近，我遇到了一些使用以下功能的代码，但是很难理解如何使用此功能。 zip（java.lang.Iterable扩展了Observable >> ws，...