代码之家 › 专栏 › 技术社区 › Peddro

RxJava2 materialize()在发生错误后不发出下一项

rx-android rx-java2 android

Peddro · 技术社区 · 8 年前

我一直在尝试将OneErrors转换为通知,以保持流发出的项目。据我所知,materialize()操作符就是这样做的。所以基本上:

materialize()/dematerialize()可用于转换终端事件进入通知

所以我根据这个问题做了一个测试( How to continue streaming items after error in RxJava? ). 我尝试了以下方法:

 @Test
public void materializeTest() {
    final Observable<String> stringObservable = Observable.fromArray("1", "2", "3")
            .flatMap(x -> {
                if (x.equals("2")) {
                    return Observable.error(new NullPointerException());
                }

                return Observable.just(x);
            })
            .materialize()
            .map(n -> n.getValue());

    final TestObserver<String> testObs = stringObservable.test();
    Java6Assertions.assertThat(testObs.values().size()).isEqualTo(2);

    testObs.assertValueAt(0, "1");
    testObs.assertValueAt(1, "3");
}

结果是,在“2”给出错误后,不会发出更多的项。我还尝试在自己的通知对象上进行扭曲( MyNotification<T> )然后做类似的事情:

stringObs
  .map(string -> MyNotification.success(string)
  .onErrorReturn(error -> MyNotification.error())

但最终的结果总是一样的:在“2”之后,不再发出更多的项目。我百分之百地做错了什么,但我真的不明白是什么。

1 回复 | 直到 8 年前

akarnokd 8 年前

具有 flatMap ,如果内部 Observable s失败时,序列终止,并且没有从上游转换其他项目。这种情况会发生之前 materialize() 甚至参与其中。

因此,与其尝试具体化合并流,不如单独具体化内部源:

Observable.fromArray("1", "2", "3")
        .flatMap(x -> {
            if (x.equals("2")) {
                return Observable.<String>error(new NullPointerException())
                                 .materialize();
            }

            return Observable.just(x)
                             .materialize();
        })
        .filter(n -> n.isOnNext())
        .map(n -> n.getValue());

推荐文章

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

8 年前

Damn Vegetables · 当N个事件中的任何一个发生时执行,但使用所有其他事件的最后结果

8 年前

Damn Vegetables · 如何压缩(s1,o1),其中s1只发生一次,o1发生多次?

8 年前

CaHa · 如何在rxjava中等待改装响应

8 年前

noloman amram99 · Android和Room:插入作品,查询不

8 年前

Martin · 可观察到。具有状态的生成器,其中异步更新新状态

8 年前

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

8 年前

idunnololz adsion · 调用dispose()之前是否需要检查isDisposed()?

8 年前

Josh Laird · 轮询第二个URL,直到JSON返回预期参数

8 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

8 年前