回答情况：
提问时间：
问题标签：
1回答
我正在使用可流动迭代器，并处理来自可迭代器的每个项目的请求。如果抛出任何异常，如何找出发生异常的输入。Flowable.fromIterable(userList) ).map(d -> updateClaimStatus(d))
浏览 0提问于2018-06-21得票数 0
在rx-java2中有Maybe.repeat()/Flowable.repeat()运算符。但是如果可能/Flowable为空，它只会无限期地重新订阅它，并且既不会发出值，也不会发出完成状态。在项目处理机中，可以使用repeatWhen()运算符： someMono.repeatWhen { it.takeWhile { i -> i > 0 } } 但是在rx-java2中，这个操作符不是这样工作的
浏览 20提问于2019-05-30得票数 1
正如在中所解释的，RxJava 2.x不再接受空值。因此，以下两行代码都以onError结束也就不足为奇了：Observable.just(1).flatMap(i -> Observable.error(new RuntimeException()));Observable.just(1).flatMap(i -> Observable.fromCallable(() -> null))
成功终止，且不发出任何项。因为它的行为方式与Observable.error相同
浏览 5修改于2019-04-15得票数 0
回答已采纳
我在rx-java2库中找不到这样做的函数。public void onComplete() { }}
但它认为它应该是标准库实现的一部分，因为它在rx-java2
浏览 2修改于2017-08-07得票数 0
回答已采纳
我正在与rx-java2作斗争。基本上，我不能安全地从Maybe“逃脱”到Single，并继续其他项目的逻辑流程。
浏览 6修改于2018-08-06得票数 1
回答已采纳
我有3个可观测的，第一个可观测的输出是第二个可观测的。第一和第二可观测的输出是第三可观测的要求。 .just("{1}") System.out.println("Executing Observable 1"); });
Observable<String> observableTwo
浏览 1提问于2018-04-11得票数 1
回答已采纳
我正在学习使用Vert.x的Rx-Java2 2，我想用一些并行任务链接一个成功的配置检索。
我创建了一个搜索配置并返回单个订阅的方法，它运行良好。
浏览 0修改于2018-04-03得票数 0
回答已采纳
尝试迁移到rx-java2时遇到了一个问题，即在它自己的flatMap中重新订阅可观察到的共享内容。
浏览 4修改于2017-09-07得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号