与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
公共类MainActivity1扩展了AppCompatActivity {private String LOG_TAG =“ MY_LOG”;私人CompositeDisposable CompositeDisposable = new CompositeDisposable（）; @Override ...
测试RxJava：AdvanceTime无法在简单的延迟可流动对象中使用
我有一个非常简单的函数，可以延迟给定的延迟值：Flowable.defer {Flow Publisher.just（Effect.Success）as Publisher } .delay（2，TimeUnit.SECONDS）....] > ] >>
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，并返回一个项目列表（这是我需要的），但是...
我从RxJava Android遇到此错误，“只有创建视图层次结构的原始线程才能触摸其视图。”我使用的代码Log.d（TAG，“ stratObserving：qw $ {Thread.currentThread（）}”）（...
我如何从Rx Java中的Single可观察值中返回值fun fetchRunResult（）：Single {return Single.just（false）} fun canRun（）：Boolean {return person.fetchRunResult（）// ...
我想将company和workFor变量合并为一个流，但是我不知道如何。我尝试使用switchMap，zip，merge和concatMapIterable，但没有任何效果。还是我做错了。。我的...
[当我看到下面的流程时，崩溃将发生在doSomethingThatWillCrash（）中，我当时在显示它会被{错误-> showError（error.message）捕获，但事实并非如此。 。
RxJava：跳过fromIterable（）中的所有错误，并在发出所有项目时通知订户-Flowable.parallel执行
我有一个API调用，可根据“ Id”验证某些状态。 API返回单一或错误。我有此类ID的列表，只有一个ID有效返回成功，否则不返回（所有ID的返回错误）。什么...
我有一个具有多个订阅者的发布主题：这是课程：类Real {私有val发布者：PublishSubject = PublishSubject.create（）fun doPublish（）{...
我在RxJava2中遇到一个不寻常的问题。基本上，我们有以下情形：用户拍照，然后按下一步开始网络请求网络请求完成后，在...
通过以下链接实现缓存：https://blog.mindorks.com/implement-caching-in-android-using-rxjava-operators fun getSavedAddressList（）：也许 ？>？ {...
我在Kotlin中有一个函数正在执行此操作：fun getItemByIds（ids：List ）：Single > {return Flowable.fromIterable（ids）.flatMapSingle {getItem（it）... ]] >
我需要合并在不同线程上运行的两个可观察对象。示例代码为val obs1 = Observable .create {{ 已迅速找到合适的解决方案：） val obs = Observable .just(1, 2) .concatMap { if (it == 1) obs1 else obs2 }
我如何使用rxjava进行异步改造调用。我必须异步拨打100个以上的电话
这里是我一直在处理项目的代码示例，其中包含100个元素，因此使用同步调用获取数据会花费大量时间。有人可以建议一种提高...
我对RxJava中的PublishSubject有疑问。我创建了一个虚拟的PublishSubject，它发出一些对象。这是我的代码：重写fun generate（exportRequest：ExportRequest）：Observable＆...
受保护的PublishSubject onScrollS = PublishSubject.create（）;公共无效onActivityCreated（...）{... recyclerView.addOnScrollListener（new RecyclerView ....
如何让地图等到当前索引项完成处理，然后使用RxJava处理下一个项？
我正在尝试将输入流转换为文件。因此，当用户选择1张图片时，一切正常。但是，当用户选择多个图像（例如4个）时，下面的代码将无法正常工作...