RxJava2：映射器函数中是否允许链接？

Question

在下面的代码中，函数 f 返回 Single

   Observable.map { line ->
              f(line).doOnError { e ->
                    println("Error:$e")
                }
        }
        .subscribe({ record -> println(record) }, { e -> println("Error2:$e") })

map中的< code>println("Error:$e")不会执行，但是我可以在订阅者中打印错误。似乎不允许在映射器函数中使用链接。正确吗？如果是，为什么？

编辑:也尝试了平面图，但结果相同。

   Observable.flatmap { line ->
              f(line).toObservable().doOnError { e ->
                    println("Error:$e")
                }
        }
        .subscribe({ record -> println(record) }, { e -> println("Error2:$e") })

Answer 1

这正如预期的那样工作:

@Test
public void test() {
    Observable.just(1)
    .flatMap(v -> single(v)
            .toObservable()
            .doOnError(w -> System.out.println("Error2 " + w))
    )
    .subscribe(v -> System.out.println(v), e -> System.out.println("Error " + e));
}

Single<Integer> single(Integer v) {
    return Single.error(new IOException());
}

指纹：

Error2 java.io.IOException
Error java.io.IOException