RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我的工作是在Http SSE流，我必须保持http连接活着。为此，我每15秒发送一个空消息（命名为心跳，其他的都命名为真实事件）。源.map(....
我正试图在Java中的websockets之上实现一个请求->响应层。我最近偶然发现了RxJava，它似乎是一个很好的库。下面是我目前的方法...
RxAndroid + Retrofit callTimeout不触发onError。
我使用RxAndroid+Retrofit进行http请求。代码如下。Interceptor headerInterceptor = getHeaderInterceptor(); HttpLoggingInterceptor httpLoggingInterceptor = new ...
在聊天应用程序中，需要处理图像--下载和上传。处理本身是在RxJava2的Observables的帮助下完成的；而下载或上传图像的命令则是在RxJava2的帮助下完成的。
将现有的WebSocket实现转换为Android Java中的Reactive WebSocket。
我在Android中使用OKHttpClient与WebSockets。我想把它转换成反应式编程。如何实现这一点。现在我正在做的WebSocket连接。/ OkHttp客户端...
我有一个任务要合并两个观测值--一个是数据库中存在的有限观测值(称之为databaseStream)，另一个是队列中的无限观测值(queueStream)。当客户端订阅时，我 ...
如何解决RxJava onSuccess()方法中的意外返回值？
我打算把我的一个方法重构为：if (!isMobileBluetoothOn()) { sendError(); return false; } to this getBluetoothState().subscribe(state>{ ...
将RXJava Single转换为coroutine的Deferred？
我有一个来自RxJava的Single，想继续使用Kotlin Coroutines的Deferred。如何实现呢？ fun convert(data: rx.Single ): kotlinx.coroutines.Deferred
如何修复错误--无法解析方法 "subscribe(anonymous rx.function.Action1<java.lang.boolean>)
我改变了Rxjava的一些与AndroidSchedulers和Observable相关的导入，当我这样做的时候，我得到了以下错误。我不知道该如何继续。错误 这些是我修改的...
如何在android mvvm中用版本库设计清除rxJava disposables？
我是MVVM的新手，想清除我的rxJava一次性用品，我看到一些答案说要在ViewModel的onClear方法中清除它，但我如何在第一时间添加一次性用品？/...
我如何能在2个不同的DAO中使用rxjava做一个房间事务？我有这样的代码，我想用Rxjava来使用，但我需要它返回某种可观察的@Transaction fun ...。
我已经阅读了RxJava的文档，并尝试下面的演示。输出是d = [0]d = false 我可以知道原因吗：为什么数据不向观察者发送 RxJava版本：2.2.6 ....
当使用Flowable(RxJava)时，如何避免RecyclerView不必要的重新渲染？
试图用房间flowable @ rxjava + retrofit2实现MVVM。当活动开始时，我从存储库中请求一个项目列表。仓库从数据库(room)中检索它们，并...
处理RxJava onErrorReturn和OnErrorNotImplementedException。
所以我想用RxJava在android中实现MVI模式，但我想在一个状态下处理抛出的错误，连同成功和加载，是否有任何方法可以处理错误，而不是从 ...
智能投向'ObserverT！'是不可能的，因为'item.get()'是一个复杂的表达式。
我将一段Java代码转换为Kotlin（Android Studio的自动转换功能），得到了下面这个错误。Java方法看起来是这样的： ** *对观察者的弱引用列表。** *观察者的弱引用列表。* ...
所以我试图使用onErrorReturn来返回我想要的结果，但它会在之后完成流，我如何抓住错误返回作为下一步，并仍然继续流？ 用下面的代码，...
如何在observableField中突变一个输入的字符串。
我有以下字段绑定到editText。 val lastName = ObservableField（MutableLiveData ()) 我想对输入的字符串进行突变，使第一个字母自动 ...
如果RxJava定时器在后台运行，Android多久会杀死应用？
所以我在应用程序的后台设置了一个RxJava定时器，每30秒运行一次。问题是这个定时器会运行，即使在应用程序处于后台时也会运行。我担心的是，AndroidOS是否会...
我是java reactive的新手，我正在为一个我认为很容易做的事情打转。我的目的是评估一个方法调用的结果，这个方法调用的结果返回一个Mono------------------。 类型...
我基本上是想在rxjava的后台线程中把一个List映射到一个字符串上，为此我使用了blocking get.它是否安全，或者有什么更好的方法来做这件事。