system.reactive
-
RxJava 和并行执行观察器代码 我有以下代码使用RxJava Observable api: 我的期望是,在我指定计算调度程序后,观察代码即subse()方法中的代码将并行执行。相反,代码仍在单线程上按顺序执行。如何使用 RxJava api 使代码并
-
如何处理观察者onNext在RxJava中引发的异常? 请考虑以下示例: 这将输出从 1 到 5 的数字,然后打印异常。 我想实现的是让观察者保持订阅状态,并在抛出异常后继续运行,即打印从1到10的所有数字。 我尝试过使用。用来绕过它似乎
-
RxJava doOnError 和 onErrorReturn 如何工作? 我做了这些单元测试,结果根本不是我预期的: 因此,两者都输出“subscribe.onError” - 既不叫也不叫。记录为: 指示 Observable 发出一个项目(由指定的函数返回),而不是在遇到错误时调
-
-
RxJava:如何在不中断链的情况下有条件地将运算符应用于可观察量 我在RxJava可观察量上有一个运算符链。我希望能够根据布尔值应用两个运算符之一,而不会“破坏链”。 我对Rx(Java)相对较新,我觉得可能有一种比我目前引入临时变量的方法更习惯和可读
-
RX:并行运行压缩可观察量? 所以我正在玩RX(真的很酷),我一直在转换我的api,它访问Android中的sqlite数据库以返回可观察量。 因此,自然而然地,我开始尝试解决的问题之一是,“如果我想进行3次API调用,获得结果,
-
RxJava - 每秒发出一个可观察的 我正在使用RxJava在Android中制作一个计时器。我需要在RxJava中创建一个计时器,每秒发出一个可观察量。我尝试了以下方法,但没有运气。对我做错了什么有什么想法吗?
标签