RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
Observable，当没有订阅者时会缓冲项目，然后在订阅时释放它们并清除缓冲区？
我想要一个可观察的对象：可以按需发出项目并且从不真正完成（热的可观察对象？）知道何时有订阅者，如果没有订阅者，它将缓冲我告诉它的项目...
我有以下可观察的：ScheduledExecutorService executorService = Executors.newScheduledThreadPool（1）; Observable > findWidgetsObservable = Observable ....
我有一个场景，我有两个可观察对象，每个都从API调用返回一个项目。我想做的是：同时执行两个api调用。为两个...设置超时值（500毫秒）...
我想发送包含多部分数据的数组对象。我尝试了很多方法，但是没有用。我的贡献者参数问题。服务器说。 contributor.0.id是必填项，并且contributor.0.role ...
我正在使用RxJava重构我的存储库的实现，因此我想知道一些编辑方法，例如，用户。我的getUser（email：String）以电子邮件作为id，正在返回一个可观察到的内容，并且...
RxJava：在发出另一个可观察对象的数据之前，阻止一个可观察对象发出]]
下面的代码块设计为脱机优先。如果数据是由可观察的内存发出的，则本地和远程可观察的对象将永远不会触发。如果数据未保存在内存中，则本地可观察到的...
使用RxJava flowable处理Android Room查询时提高性能
我的应用正在以尽可能高的采样率（在我的设备上为〜200 Hz）从加速度计收集传感器值，并将这些值保存在Room数据库中。我也想经常更新...
我正在使用RxJava编写一些发布/订阅代码。我发现我们必须使用以下模式：observable.subscribe（observer），但据我了解，我们应该说一个句子，例如“ observer订阅...
我对使用反应流非常陌生，遇到了以下问题，这使我很难解决。目的是从MongoDB数据库中获取许多文档。 ...
在JWT用户映射期间创建Gentics网格用户配置文件节点-导致失败
我正在使用JWT解析的身份验证插件，以获取详细信息并更新Mesh中的用户。我还要创建一个新节点，并使用用户将其附加到网格中的用户。...
reversRange（int from，int to）{Stream intStream = Stream .... ] >
如何在RxJava 2中从无限流创建Observable [？
reversRange（int from，int to）{Stream intStream = Stream .... ] >
如何在RxJava 2中从Stream ？]创建Observable ??
我正在尝试将RxJava从1升级到2。在我的旧代码中，我有一个方法reverseRange：private Observable reversRange（int from，int to）{Stream intStream = Stream ....
我有以下代码可以正常工作。但是，我不喜欢blockingGet。有没有一种方法可以将getSingle（）调用上移到Observable的'global'变量中，以......>
我正在使用rxJava学习设计模式，并且遇到了异常的输出。通过输出isAbove变量，我向控制台输出true和false。期望值应为...
我无法绕过正确的语法来执行以下操作：创建仅执行一次且从不调用onComplete的Hot Observable，让其他Observable监听并响应...
我想知道最干净的方法是使用RxJava语法遍历一个集合，如果不存在任何项，则会引发错误。下面显示了一个混合示例，但理想情况下，我希望所有逻辑...
如何结合翻新和LocalDB请求并将结果提供给MVVM中的RecyclerView？
我想从改造中获得结果，如果可能的话，将此数据发送到livelive之类的recyclerview适配器，并保存在本地数据库中。如果翻新无法获得结果数据，则应从本地加载...
我曾经认为RxJava 2的Flowable设计为“热”和可观察的“冷”。但是我认为现在是错的-Observable和Flowable都很冷但是可以变热，例如通过使...