与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
Kotlin Coroutines中是否有RxJava Subject的类似物?
[2020年,许多Android开发人员都在谈论Kotlin Coroutines。我想了解它以及协程如何在我的项目中为我提供帮助。所以我的问题是:协程中是否有类似物用于...
为什么此代码不发出任何东西:Observable observable1 = Observable.interval(3,1000,TimeUnit.MILLISECONDS); observable1.subscribe(l-> System.out.println(l));
我刚刚在项目中添加了实现“ org.jetbrains.kotlinx:kotlinx-coroutines-rx2:1.3.3”。我暂停了foo():类A中的Flow (来自外部包)。我需要得到...
我有一个Observer对象,该对象已在Observable上订阅。该Observable对数据库执行SQL查询,获取多个结果,然后执行.forEach(...)现在,我需要添加第二个SQL ...
RxJava2 concatArrayEagerDelayError在请求获取远程数据时引发错误时不加载缓存的数据
[我正在Android项目中使用以下代码从数据库(缓存)和API请求加载数据:Observable.concatArrayEagerDelayError(getDatabaseData(),getRemoteData())。...
我已经将一些JAVA类转换为Kotlin,但是我在Android Studio中遇到Type Mismatch Error问题。我在IDE中为...
Maybe的响应式(rxjava)问题 vs Flowable等
我仍在学习react / rxjava的一些细节,并对我经常遇到的用例有一个快速的问题。我们经常有从数据库或其他数据中获取条目的服务...
我是Rx世界的新手,我已经看到了多个如何处置Disposable的示例,但我不太了解其中的区别。我正在使用RxJava 2.0(v2.2.17)和RxAndroid(v2.1.1)。我的问题是...
我有此代码:private Single getInvoiceWithItems(){return getInvoice()。flatMap(invoice-> getItems(invoice))); //
我有此代码,可以从缓存中获取照片,然后再从API中获取照片。一次性=相片photosRestoreory.getPhotoAttachments(workOrderId)....
retrofit2 rxjava 2-出现错误时如何访问响应正文
我与Rxjava一起使用Retrofit来请求服务器。我的服务器返回定义的json格式,其中包括data和定义的消息。服务器返回http响应。服务器返回就可以了...
如何通过正确的Crashlytics错误分组获得更好的RxJava stacktrace
[我的目标是:将RxJava链处理的错误记录到Firebase Crashlytics中。获取一些合理的堆栈跟踪信息(这也指向我的代码)使Firebase Crashlytics错误分组正确(并非全部...
[android / kotlin-在单击“后退”按钮时,使用CompositeDisposal(RXjava2)进行改装无法转到响应/可抛出的块]
[在Kotlin中,打开活动或片段时,我可以以这种格式调用api并获得响应而没有任何问题:CompositeDisposable.add(dataManager .getHistory()...
Kotlin Flow on BackpressureDrop RxJava2类似物
在RxJava 2 Flowable中,有不同的背压策略,其中最有趣的是:最新的缓冲区下降,在整个Rx链中都受到尊重。在Kotlin中有Flow,...
发出第一个元素或为空后在Observable上调用onComplete
我有一个名为myObservable的Observable,我的目标是为所发射的第一个元素调用onComplete,或者在发射为空时调用它。所以我正在这样做:myObservable.firstElement()....
致命异常:java.io.InterruptedIOException:与rxjava一起使用改造时线程被中断
[我收到此随机异常,使我的应用程序在进行翻新的网络调用时崩溃,并且正在寻找解决方法的指南致命异常:java.io.InterruptedIOException:线程...
私有HashMap 项目=新的Hashmap <>();私有Flowable 您可以创建一个返回Flowable的包装器。然后,您应该覆盖put函数并使用该Flowable发出更改。
我们有一个字符串Observable。如果更改,则它将发出新值,并且数据将不进行任何更新。观察者应每秒观察一次String值。我尝试这样做,但是...
我已经按照这篇文章介绍了如何在WorkManagers上进行DI,所以我有这个工厂:类MyWorkerFactory @Inject构造函数(val workerFactories:Map ,...
我有来自API的单个GET请求。使用Retrofit和RxJava,我得到了回应。现在,我要将响应添加到“房间”数据库中。但是我不想使用AsyncTask,我想使用RxJava。我...