RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
跟踪specifec zipped使用Rxjava zip运算符时出现Observable错误
如果我有一个案例，我使用Rxjava zip运算符，让我们说它拉链4个不同的网络调用。例如：Observable.zip（networkCall1，networkCall2，networkCall3，networkCall4），（model1，model2，...
我有两个observable：Observable O（open）：在textview中打开一些内容的文件Observable E（编辑）：在textview中编辑的文件内容我想去抖E observable，并将它与O合并...
在Android Activity生命周期中进行改造以保持数据新鲜
我的改造接口方法返回rx Single，响应@GET（“/ data”）Single >> getData（）;在我的Activity onStart（）方法中，我将getData（）调用到...
我制作了一个地理标记的社交报告应用程序来报告Android上破碎的街道。它需要位置数据来发布报告。从照片的Exif，Gps传感器或手动设置...
RxJava jersey客户端，带有使用WebResourceFactory构建的代理
有没有人知道如何使用客户端代理构建反应式rx java客户端？官方文档：https：//jersey.java.net/documentation/2.23.2/rx-client.html仅提供示例...
我是RxJava的新手，目前正在使用RxJava的第1版。我的用例就像我必须进行一次其他API调用（使用rest模板）。因此，最好使用Schedulers.computation（）或任何...
我有一个方法：可观察 > getNames（）;我有对象Person与构造函数Person（）和Person（String name）还有一个空列表ArrayList ...
我有两个Observable，让我们称它们为Peanut Butter和Jelly。我想将它们与三明治观察结合起来。我可以使用：Observable 花生酱可观察= ...; ...
我有以下场景：我有一个名为Foo的对象我的应用程序感兴趣。这个Foo对象来自一个远程服务，我想在本地缓存这个实例并保持...
RxAndroid / RxLifeCycle - 处理处理onError而不是onComplete
我目前正在尝试将RxLifeCycle实现到我与RxJava的网络中。我一直在使用Consumer的子类，但是对于RxLifeCycle，你需要处理onError。所以我已经搬到了Observer。 ...
编辑：我的答案在下面我有一个特定的场景，我可以使用一点指导。我有一个POST端点，我想调用一些异步方法（我不关心结果，所以...
RxJava：无法为rx.Observable错误创建调用适配器
我做什么：公共接口ApiInterface {@Multipart @POST（“/ android / upload / index.php”）可观察 postImage（@Part MultipartBody.Part图片，@ Part（“name”）...
我有一个包含键/值对的地图。从这张地图中我通过流式传输将它们存储到一个数据库中，该数据库作为结果返回Observable 。当我试图达到这个字符串时，我的问题来了......
我正在使用需要查询的Api：电影发行年份的标题但我的另一个Api只给我一个特定国家的发行年份，所以我可能要重试请求...
我是RX java的新手。尝试使用订阅者创建使用者，但我看到不推荐使用create方法。我看到几乎所有其他创建方法，除了具有Emitter类的方法，...
rxJava debounce运算符不使用Observable.range（）
AFAIK是rxJava的debounce（）运算符，用于延迟事件的发射。当我用搜索框应用它时，它正常工作：RxTextView.textChangeEvents（editText）.debounce（...
你可以帮助我这个rxkotlin groupby不工作吗？在rxjava工作但不是kotlin。非常赞赏你的帮助
RxJava / RxJs：如何合并两个源可观察对象，但只要其中一个完成就完成
我有两个源可观察量。我想合并两个源可观察对象，但是只要其中一个源可观察对象完成，合并的可观察对象就会完成。期望的行为：来源......
RxAndroidBle：如果客户端处于可观察状态，如何执行读写操作？
建立连接时，我使用.asObservable（）属性保持连接。 bleDevice = rxBleDevice; rxBleDevice.establishConnection（false）.flatMap（RxBleConnection :: discoverServices）...
如何使用RxJava过滤项目列表？我有以下代码，loadData（）发出一个List ：repository.loadData（）.subscribe（chatrooms - > {view ....