rx-java2 相关问题

与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。

Kotlin Coroutines中是否有RxJava Subject的类似物?

[2020年,许多Android开发人员都在谈论Kotlin Coroutines。我想了解它以及协程如何在我的项目中为我提供帮助。所以我的问题是:协程中是否有类似物用于...

回答 1 投票 1

为什么间隔什么都不发出?

为什么此代码不发出任何东西:Observable observable1 = Observable.interval(3,1000,TimeUnit.MILLISECONDS); observable1.subscribe(l-> System.out.println(l));

回答 2 投票 0

如何将Flow转换为Flowable?

我刚刚在项目中添加了实现“ org.jetbrains.kotlinx:kotlinx-coroutines-rx2:1.3.3”。我暂停了foo():类A中的Flow (来自外部包)。我需要得到...

回答 1 投票 1

RX Java将可观察变量与一对多关系结合起来

我有一个Observer对象,该对象已在Observable上订阅。该Observable对数据库执行SQL查询,获取多个结果,然后执行.forEach(...)现在,我需要添加第二个SQL ...

回答 1 投票 0

RxJava2 concatArrayEagerDelayError在请求获取远程数据时引发错误时不加载缓存的数据

[我正在Android项目中使用以下代码从数据库(缓存)和API请求加载数据:Observable.concatArrayEagerDelayError(getDatabaseData(),getRemoteData())。...

回答 1 投票 0

可观察到的转换为kotlin-问题

我已经将一些JAVA类转换为Kotlin,但是我在Android Studio中遇到Type Mismatch Error问题。我在IDE中为...

回答 2 投票 2

Maybe的响应式(rxjava)问题 vs Flowable等

我仍在学习react / rxjava的一些细节,并对我经常遇到的用例有一个快速的问题。我们经常有从数据库或其他数据中获取条目的服务...

回答 1 投票 0

如何在RxJava2.0中处理可抛弃物>>

我是Rx世界的新手,我已经看到了多个如何处置Disposable的示例,但我不太了解其中的区别。我正在使用RxJava 2.0(v2.2.17)和RxAndroid(v2.1.1)。我的问题是...

回答 1 投票 0

如何使用Single.flatMap合并两个值?

我有此代码:private Single getInvoiceWithItems(){return getInvoice()。flatMap(invoice-> getItems(invoice))); //

回答 1 投票 0

如何将RxJava代码改进为API和本地缓存?

我有此代码,可以从缓存中获取照片,然后再从API中获取照片。一次性=相片photosRestoreory.getPhotoAttachments(workOrderId)....

回答 1 投票 0

retrofit2 rxjava 2-出现错误时如何访问响应正文

我与Rxjava一起使用Retrofit来请求服务器。我的服务器返回定义的json格式,其中包括data和定义的消息。服务器返回http响应。服务器返回就可以了...

回答 1 投票 0

如何通过正确的Crashlytics错误分组获得更好的RxJava stacktrace

[我的目标是:将RxJava链处理的错误记录到Firebase Crashlytics中。获取一些合理的堆栈跟踪信息(这也指向我的代码)使Firebase Crashlytics错误分组正确(并非全部...

回答 1 投票 4

[android / kotlin-在单击“后退”按钮时,使用CompositeDisposal(RXjava2)进行改装无法转到响应/可抛出的块]

[在Kotlin中,打开活动或片段时,我可以以这种格式调用api并获得响应而没有任何问题:CompositeDisposable.add(dataManager .getHistory()...

回答 1 投票 0

Kotlin Flow on BackpressureDrop RxJava2类似物

在RxJava 2 Flowable中,有不同的背压策略,其中最有趣的是:最新的缓冲区下降,在整个Rx链中都受到尊重。在Kotlin中有Flow,...

回答 1 投票 3

发出第一个元素或为空后在Observable上调用onComplete

我有一个名为myObservable的Observable,我的目标是为所发射的第一个元素调用onComplete,或者在发射为空时调用它。所以我正在这样做:myObservable.firstElement()....

回答 1 投票 0

致命异常:java.io.InterruptedIOException:与rxjava一起使用改造时线程被中断

[我收到此随机异常,使我的应用程序在进行翻新的网络调用时崩溃,并且正在寻找解决方法的指南致命异常:java.io.InterruptedIOException:线程...

回答 1 投票 7

如何创建将听取哈希表更改的函数?

私有HashMap 项目=新的Hashmap <>();私有Flowable 您可以创建一个返回Flowable的包装器。然后,您应该覆盖put函数并使用该Flowable发出更改。

回答 1 投票 0

如何观察字符串值的周期性变化?

我们有一个字符串Observable。如果更改,则它将发出新值,并且数据将不进行任何更新。观察者应每秒观察一次String值。我尝试这样做,但是...

回答 1 投票 0

RxWorker即使没有安排也被多次调用?

我已经按照这篇文章介绍了如何在WorkManagers上进行DI,所以我有这个工厂:类MyWorkerFactory @Inject构造函数(val workerFactories:Map ,...

回答 1 投票 3

无法将来自API的响应添加到数据库中

我有来自API的单个GET请求。使用Retrofit和RxJava,我得到了回应。现在,我要将响应添加到“房间”数据库中。但是我不想使用AsyncTask,我想使用RxJava。我...

回答 2 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.