与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
我有一个可观察的序列。当插入第一个元素时，我想启动一个计时器，并在计时器的时间范围内对随后插入的元素进行批处理。然后，计时器将无法启动...
我是Rx Java的新手，我想从多个API中获取数据。这些API彼此独立，但是我想在View中显示这些API的数据。所以我想做...
我正在尝试将我的单声道拆分为其他分离的单声道，该单声道将在不同线程上处理相同的数据输入数据。公共Mono process（）{Mono ...
RxJava为列表中的每个项目通过Android中的Retrofit发出api请求
我的Android项目中存在以下问题：我有一个元素列表（ArrayList），该列表是从上一个使用Retrofit进行网络调用获得的。 CategoryItem看起来像这样：公共类CategoryItem ...
java.lang.RuntimeException：无法在没有参数的情况下调用public io.reactivex.Observable（）
[您好，我目前正在准备一个带有协程的MVVM的简单演示示例，我正面临以下问题。请查看代码以及代码有什么问题。 E / AndroidRuntime：FATAL ...
使用Firebase InstanceID和RxJava 2.0的异常（MAIN_THREAD）
我们的应用程序使用以下代码获取FirebaseInstanceId：Observable.create {it.onNext（FirebaseInstanceId.getInstance（）.getToken（SENDER_ID，...
在Android中使用RxJava窗口或缓冲区进行批处理吗？
我希望在api帖子之前实现批处理机制，以进行一些简单的事件收集和记录。由于这是Android设备，因此我也想处理此服务的生命周期事件...
映射可选项时，RxKotlin出现意外的NullPointException
首先，我有以下Moshi json。 @JsonClass（generateAdapter = true）数据类OrderDetails（@Json（name =“ _id”）val id：Int，@Json（name =“ status”）val status：字符串，@Json（...
在这种情况下，我需要别人的帮助：在这里，我的对象的格式为：{“” transport“：true，” fraisTransport“：” string“” cars“：[{” id“：” string“，” prix“：”字符串“，” photo_url1“：...
我想监视片段是否已添加到活动中。我有活动实例，我正在非活动类中使用它来监视是否有任何片段添加到活动中。我已经创建了...
我经常发现自己创建的流取决于Single 提供的某些条件。考虑下面的示例：@Test public void test（）{Observable.range（0，10）....
RxJava2：如何在处置订阅者后避免InterruptibleException？
我有一个可观察对象：public Observable > getConversationListObservable（）{返回Observable.create（发射器-> {List 对话= ...
Observable，当没有订阅者时会缓冲项目，然后在订阅时释放它们并清除缓冲区？
我想要一个可观察的对象：可以按需发出项目并且从不真正完成（热的可观察对象？）知道何时有订阅者，如果没有订阅者，它将缓冲我告诉它的项目...
RxJava retryWhen重试返回可完成结果的整个方法
我试图在API每次以无效令牌错误（重新身份验证）响应时重新验证令牌。我有这个小例子，它复制了我面临的问题。基本上，第一个呼叫是...
我有以下可观察的：ScheduledExecutorService executorService = Executors.newScheduledThreadPool（1）; Observable > findWidgetsObservable = Observable ....
我有一个接口，该函数返回Flowable接口Iface {Flowable get（）; }现在让我们假设具体的实现是：类IFaceImpl {int noOfSecs = ...
冗长的后台操作，并且具有FOR循环。循环中的每次迭代完成后，我需要更新UI。我如何才能在RX Java中实现这一点而无需等待所有迭代都得到...
将异步调用转换为RxJava，在处理完所有项目后如何手动完成？
我有一个自定义类，用于将单个文件或多个文件上传到Firebase存储：公共类FirebaseUploader {private Context appContext;私有FirebaseStorage存储； ...
我需要遍历视图模型列表，对视图进行充气并将其添加到linearLayout中。任何有关如何执行此操作的提示都将不胜感激。 @BindingAdapter（{“ items”，“ provider”}）...