RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
当一个observable's on next被触发时，可补全表必须完成。
我有一个Observable如下： public Observable > getObjectsForUser() { return Observable.fromCallable(() -> { if (objects.size() < 1) { ....
我想改进观测值的doOnNext块中的睡眠。如果有更好的方法，请推荐。Observable.from(sampleList) .buffer(5) .doOnNext(first -> {....
首先，我还是RX Java的新手，但我了解到Single.create仅发出一个可观察的信号，这就是发生的情况，但问题是该函数本身执行了两次，因此我如何制作我的...
在什么情况下需要在RxJava中使用blockingSubscribe？像考虑以下内容一样，它可以打印结果。 Observable.just（1、2、3、4、5）.subscribe（line-> System ....
EventBus / PubSub与（反应性扩展）RX在单线程应用程序中的代码清晰度有关
[当前，我正在使用带有Scala（和JavaFX）的EventBus / PubSub体系结构/模式来实现一个简单的便笺组织应用程序（有点像Evernote客户端，并带有一些附加的思维导图...
我在项目中将RxJava3与Room一起使用，但是出现以下错误错误：不确定如何将游标转换为此方法的返回类型（io.reactivex.rxjava3.core.Flowable>），下面是...] >
创建一个等待所有Schedulers.io（）完成的Mockito测试用例
我有一个错误，只有在并行运行时，例如在Schedulers.io（）上，它才会显现出来。修复很简单-用concatMapCompletable替换flatMapCompletable以显式执行...
我如何合并一个返回一个数组的调用，并对该数组的每个元素进行多次调用？
很抱歉，该标题不够清楚，但我不知道如何用一句话来总结。我有一个Web服务，它返回名为父亲的对象的ArrayList。父对象是结构化的...
RxJava是否在后台进行了多线程处理，例如，如果下面的可观察对象发出了事件hello，是否通过创建新线程来完成？ Observable observable = Observable.just（“ Hello”）;如果...
在更新关于RxJava / RxAndroid进度的UI时发出单个项目
我目前正在尝试在Android中学习RxJava。我需要一些指南。此刻，我正在尝试将下面的AsyncTask重写为RxJava：公共类MyAsyncTask扩展了AsyncTask <>
Firebase + RxJava，onComplete（）事件
没有人知道如何将Firebase与RxJava连接，因此当我从数据库加载所有数据时，它会运行arrayAdapter.notifyDataSetChanged（）？我在想用onComplete（）方法编写它...
我有以下代码：Single.create {发射器-> // I / O线程在这里ThirdPartySDK.doSomeAction {//此处的主线程generator.onSuccess（someValue）}} .flatMap {...
我如何在另一个线程上运行RxJava，因为主线程上的工作太多。我在一个方法中运行了Observer，这是代码段：public void updatePie（）{...
我想知道是否可以使用RxJava库在以下用例中添加一些并发性：使用自定义Observable（...
我一直在测试我们的业务逻辑的问题单元。问题是当我想对实时数据的所有排放进行单元测试时。现在我只得到最后一个发出的值，但我想...
我有一个方法，它接收对象列表（小部件）-包含一些属性（标题）和嵌套列表（组件）。我想将列表展平为一个列表，并使用以下代码...
我需要填写对象的字段才能将其发布到API。我正在使用rxjava和room，但是命令链出现故障我的daos @Dao抽象公共类PokemonDao实现了...
retrofit.HttpException：HTTP 400错误的请求android（关闭）
我正在尝试实施基本的用户注册。我正在使用RxJava和改造（v2 beta）。 URL：http://momento-w03d.c9users.io/register字段用户名密码全名电子邮件当我使用邮递员时...
如何设置集合运算符，以便始终获得上一个值和当前值？如果可能的话，我想避免在管道外创建状态。 -时间-> 1 2 3 4 | | ...
我正在尝试使用RxJava和AsyncHttpClient并行调用多个Web服务，然后处理每个服务的结果。我需要将等待服务的时间限制为...