与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
Rxjava - 组合 Singles 并生成数据类 Single
我有一个关于单身的问题，但还没有找到一个好的答案。 我必须从获得 2 个 Single 源的方法中返回 Single。问题是我需要使用输出...
无法使用 TestSubscriber 订阅 RxJava 2 Observable
为什么我的编译器不允许我使用 TestSubscriber 订阅 Observable？ 这是我的代码： TestSubscriber testSubscriber = new TestSubscriber<>(); Observable.ju...
有没有更好的方法在android中用rxjava实现单源真值
在我的应用程序中，我有使用Room的数据库和使用retrofit的网络服务。我有一个要求，如果本地数据库中没有数据，我需要查询网络并显示一个进度条。如果...
测试RxJava BehaviorProcessor是否发出了一个值。
我很难理解为什么所有这些处理器都能通过测试，而Behavior却不能：package com.example; import org.junit.Test; import io.reactivex.Flowable; import io.reactivex...。
RxJava 单独过滤一个列表对象内部并返回其对象与过滤后的列表。
我正在使用RxJava2（Single）与retrofit进行网络请求，当接收响应时，amog对象包含的其他字段，有一个对象列表，我试图实现的是过滤 ...
在RxJava2中，Publisher和Flowable的Mutiny对应的是什么？
我想创建一个缓冲的Multi，我可以将对象推送给它。这个Multi是作为一个REST端点的结果使用的。到目前为止，我所拥有的是： class MyService { private PublishProcessor
我正在重构我们的部分代码，对我的一个具体问题的推理感到不确定。我们的业务需求如下。我们必须分别从不同的地方调用4个网络请求...
我的工作是在Http SSE流，我必须保持http连接活着。为此，我每15秒发送一个空消息（命名为心跳，其他的都命名为真实事件）。源.map(....
假设我有一个输入参数列表：val array = arrayOf(input1, input2, ... inputN) / N通常小于10，我必须通过做一些重计算来处理这些参数。所以要...
有没有一种单一的订阅流，不会抛出异常。而是自动取消旧的订阅？
标题几乎描述了所有的事情。我发现自己经常这样做。StreamSubscription willDismissPageStreamSubscription; @override void initState() { ....
使用RxJava用ConfirmationDialog管理ViewState。
覆盖fun submitIntent()。Observable > { AlertOP.showPasswordVerificationDialog(requireContext(), object : GeneralDialogListener{ override ...。
在聊天应用程序中，需要处理图像--下载和上传。处理本身是在RxJava2的Observables的帮助下完成的；而下载或上传图像的命令则是在RxJava2的帮助下完成的。
RxJava 用Observable和take操作符读取文件的问题。
我的工作环境是JDK 1.6和RxJava 2，我想做一个Observable，它发出的项目是通过BufferedReader读取的文件行字符串，如下所示。... 观察者 ...
RxJava - 如何用takeUntil操作重复两个观测值，其中一个观测值取决于其他观测值。
我有一个场景，我需要调用search api根据地图上的搜索半径来获取一个特定项目的列表。要求至少显示五个结果。在我的案例中，我有两个Apis（两个 ...
我有一个任务要合并两个观测值--一个是数据库中存在的有限观测值(称之为databaseStream)，另一个是队列中的无限观测值(queueStream)。当客户端订阅时，我 ...
虽然我已经写了很多年的Java代码，但我几乎没有用RxJava做过任何工作，我需要了解如何将其映射到预期的结果。我有很多现有的服务代码，我...
在执行AndroidSchedulers.mainThread()时出错。
我有一个片段，我已经实现了一些代码： public void onViewCreated(@androidx.annotation.NonNull View v, @Nullable Bundle savedInstanceState) { super.onViewCreated(v, ...
如何修复错误--无法解析方法 "subscribe(anonymous rx.function.Action1<java.lang.boolean>)
我改变了Rxjava的一些与AndroidSchedulers和Observable相关的导入，当我这样做的时候，我得到了以下错误。我不知道该如何继续。错误 这些是我修改的...
如何检查一个表达式的结果是否被用于自定义的Android lint规则中
我想写一个lint规则来捕捉RxJava2函数的结果没有被使用的地方。例如： final Observable observable = getObservable(); observable......。
如何在Java中正确使用Apollo客户端的RxJava2库进行同步调用？
RxJava2是可以用于Apollo GraphQL JVM的。但我可以找出如何正确使用它。我试图同步使用它。** *这个方法应该是发送一个Apollo Call, 映射数据...