RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我如何合并一个返回一个数组的调用，并对该数组的每个元素进行多次调用？
很抱歉，该标题不够清楚，但我不知道如何用一句话来总结。我有一个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服务，然后处理每个服务的结果。我需要将等待服务的时间限制为...
我在Android应用中使用RxJava2。我想知道是否可以使用类似flappMap的方法来处理错误。所以，我想知道的是：是否有任何方法返回另一个...
使用Android Clean Architechture处理来自API的错误和成功响应
我正在尝试在我的应用程序中实现Clean Architecture。我的API在成功和失败情况下发送响应，例如：{“ data”：[]，“ statusCode”：200，“ statusMessage”：“ success”，“ success”：true ...
没有人知道如何执行以下操作：必须解析元素的内容，并且必须通过进行并行查询对子元素进行分组。您应该前进到列表中的下一个项目...
为什么要在与PriceResource Publisher的多个连接中，只有一个获得流？
似乎只有一个http客户端获取数据流，而其他HTTP客户端没有。发布者是热门数据，是否应该向所有订阅者广播，这是真的吗？请在...
AsyncSubject可以处理RxJava中的SingleLiveEvent情况吗？
问题一次性事件的反应式编程模式的问题在于，可能在最初的一次性事件发生后将它们重新发送给订户。对于LiveData，...
RxJava，等待多个Observable在同一时间提供所需的结果
我有多个Observable 从“警报传感器”传递数据。他们只提供价值变化。如何等待直到所有这些都切换为false，这才表明没有...