RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
RxAndroidBle：如果客户端处于可观察状态，如何执行读写操作？
建立连接时，我使用.asObservable（）属性保持连接。 bleDevice = rxBleDevice; rxBleDevice.establishConnection（false）.flatMap（RxBleConnection :: discoverServices）...
如何使用RxJava过滤项目列表？我有以下代码，loadData（）发出一个List ：repository.loadData（）.subscribe（chatrooms - > {view ....
如何在RxJava / RxScala中缓存observable
我有一个REST API，使用基于RxScala的反应式scala驱动程序调用mongodb。在我的API控制器或服务层中，我需要使用缓存来避免使用mongodb调用...
在使用rxjava进行一些编码后，你会以一种完全不同的方式思考，当我想要一些操作来保存集合中的一些数据时，我仍然无法理解我应该怎么做（让我们说一个地图......
如何使用ConnectableObservable预取并随后使用不同订户的已处理数据
在我的应用程序中，我需要在应用程序启动后立即加载大量数据。此外，我需要在某些片段/活动中加载数据时收到一个事件。我正在使用RxJava ......
如何在Activity中使用Retrofit和RxJava / RxAndroid处理旋转？
我在这里读到我们可以使用一些全局缓存来处理旋转。您可以通过使用缓存或重放Observable运算符来防止这种情况，同时确保Observable以某种方式存活...
我在Android应用程序上使用MVVM，我想在设备轮换时管理请求和rxJava，如何在旋转设备和上次请求后计数后禁用请求？这是我的简单......
我有一个从外部源更新的列表。我想要的是一个observable，随着更多项目添加到列表中，它会以固定的延迟发出单个项目。我想用RXJava做到这一点。 ...
我正在使用retrofit和rxjava从网络下载一些文件。在我的应用程序中，用户可以取消下载。伪代码：订阅订阅= Observable.from（网址）....
我希望我的应用程序能够连续扫描最多3个不同的BLE外围设备（由MAC地址标识）。找到一台设备后，我会停止扫描并连接到它。代码：静态可观察
RxJava 2：Observable.create（）等待使用Thread.sleep（）完成异步代码
我使用Observable.create（...）包装一些异步代码。异步代码需要“活动”五秒钟，然后才能停止。这就是我目前停止它的方式：可观察。
RxJava2中的“unsafeSubscribe（）”运算符发生了什么变化？
在https://rxjava-doc.readthedocs.io/en/latest/What%27s-different-in-2.0/中没有提到它，我在编码时无法在建议中看到它。我可以看到“safeSubscribe（）”。是吗......
如何刷新Retrofit2 / rxJava中的ACCESS-TOKEN
我发出请求（任何，授权，注册等），然后我发现我需要更新ACCESS-TOKEN，也就是说，我收到错误401.这是授权请求：...
这个问题与这个问题松散相关，但没有答案。 Bob Dalgleish的答案很接近，但不支持来自Single的潜在错误（我认为......
如何在rxjava中重试时使用RetryAfter Header
当存在异常时，我有以下重试代码.retryWhen（new Func1 ，Observable >>（）{@ Override ...
有没有办法转换HystrixCommand所以它被用作rxJava2的Single对象？其主要目标是并行调用多个HystrixCommands并等待它们全部完成（如...
我有两个单打定义如下。单 userSingleA = Single .fromCallable（（） - > {//从镜像A返回用户获取用户数据的函数;}）; ...
除了ObservableSources的数量之外，RxJava2中的concat和concatArray有什么区别吗？ Observable.concat（observable1，observable2）Observable.concatArray（observable1，...
我很沮丧地在swift上搜索这个java代码的等价物：public abstract class BaseApiSubscriber 扩展订阅者 {private WeakReference ...
我需要在冷热Observable之间有一些东西。它应该在客户端订阅时发出项目，并在客户端取消订阅时停止发送。但是当客户订阅同一个Observable时......