RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我有新闻清单。当用户单击新闻之一时，我将显示完整的新闻信息。在那一刻，我在标头中将此消息的别名发送到后端请求。有时我的应用程序崩溃。但是这个请求有...
我在RxJava2中遇到一个不寻常的问题。基本上，我们有以下情形：用户拍照，然后按下一步开始网络请求网络请求完成后，在...
通过以下链接实现缓存：https://blog.mindorks.com/implement-caching-in-android-using-rxjava-operators fun getSavedAddressList（）：也许 ？>？ {...
我如何使用rxjava进行异步改造调用。我必须异步拨打100个以上的电话
这里是我一直在处理项目的代码示例，其中包含100个元素，因此使用同步调用获取数据会花费大量时间。有人可以建议一种提高...
我想知道如何最好地组合两个流，每个流在RxJava中具有相同持续时间的独立超时，而不会导致崩溃错误。在RxJava中，如果运行以下代码，则......>
我不确定我是否错过了MvRx，MvRxTestRule或RxJava中的内容。通常在ViewModel中，我想测试网络调用以及是否触发另一个调用。所以当我有这样的东西：...
为什么我无法使用RxJava合并两个Single Android Room结果
为什么Single.concat（..，..）。toObservable（）不只返回一个可观察的观察值？我正在使用Android Room数据库中的搜索功能，它们来自具有相同结果类型的不同来源。我...
我想进行应用程序范围的Internet连接监视，为此，我正在使用rxjava，我制作了一个util类，并获得了用于连接状态的静态方法，如下所示：val ConnectivityManager = ...
我的设置是以下活动：onCreate（捆绑保存的InstanceState）{myViewModel.getData（intent.getParam）.observe（this，this :: dataDisplay）; } ViewModel getData（String param）{return ...
我在我的存储库实现中遇到了一个奇怪的问题。每次我调用应该从数据库获取数据并通过网络调用更新数据库的函数时，都会收到...
使用RxJava从可观察的调用返回不可观察（Android / Kotlin）
我有一个接受布尔输入值的函数，并且在这种情况下，它需要在一种情况下订阅一个Observable，而在另一种情况下需要立即返回。看起来像这样：...
Retrofit + Gson + RxJava解析失败时抛出错误
[使用Retrofit + Gson + RxJava时出现一些奇怪的行为，这是我的检索对象Retrofit.Builder（）.baseUrl（Constants.Urls.URL_BASE）.addConverterFactory（...
我需要在收到事件后的X秒内执行一些操作（代表任何数据项rxJava）。但是，如果在X秒结束前又发生了另一个事件，则计时器重置并需要再次执行操作...
如何使用在核心库中出售的运算符来递归地生成RxJava Flowable？
下面的简单程序最终挂起。 // Kotlin包com.example import io.reactivex.rxjava3.core.Flowable import io.reactivex.rxjava3.core.Single import io.reactivex.rxjava3.schedulers ....
我在使用Android Room时应该考虑哪些例外。从我的研究中，我发现可能只发生一种异常。房间例外情况也就是您...
我实际上是rxjava的新手，并试图通过我的dao在returng Single的房间中使用它，但是在构建时我一直找不到符号返回RxRoom.createSingle，以下是我的dao @ ...
了解RxJava onBackpressureBuffer中的容量参数
[这是我写的一个小示例应用程序：包ru.maksim.sample.app导入android.os.Bundle导入android.util.Log导入androidx.appcompat.app.AppCompatActivity导入io.reactivex.rxjava3 ....
我想知道Schedulers.io（）是否将按照调用者的顺序执行任务。公共类SaveTest {@Inject private MyRepository myRepository; public void save（）{...