我如何将throwable传播到Completable的下一个链？

Question

我正在使用RxJava开发Android应用。

我有一些API调用链。

1. 验证
2. 消费

val verify = Completable.error(Exception("TEST"))
            .doOnSubscribe { Log.d(TAG, "1. verify") }
            .doOnComplete{ Log.d(TAG, "1. verify - success") }
            .doOnError { Log.e(TAG, "1. verify - failed: ${it.message}") }
            .retryWhen { attempts ->
                attempts.zipWith(
                    Flowable.range(1, 3), BiFunction<Throwable, Int, Long> { t, i ->
                        if (i <= 3) {
                            1L
                        } else {
                            throw t
                        }
                    }
                ).flatMap {
                    Flowable.timer(it, TimeUnit.SECONDS)
                }
            }

// 2. consume
val consume = Single.just("SUCCESS")
    .doOnSubscribe { Log.d(TAG, "2. consume") }
    .doOnSuccess { Log.d(TAG, "2. consume - success") }
    .doOnError { Log.e(TAG, "2. consume - failed: ${it.message}", it) }

disposable.add(
    verify.andThen (consume)
        .subscribeOn(ioScheduler)
        .observeOn(uiScheduler)
        .subscribe({
            Log.d(TAG, "done")
        }, { t ->
            Log.e(TAG, "failed: ${t.message}", t)
        })
);

我除外...

“验证”应每1秒调用3次。

3次重试失败后，应该执行Error。

但是就我而言，“ consume”也已运行。

为什么？

如果“验证”失败，我想跳过“消费”！

我该怎么办？

Answer 1

这是因为您的代码没有失败。

使用Flowable.range(1, 3)，您将创建1到3的范围，因此永远不会到达代码的else部分。

尝试使用Flowable.range(1, 4)，您将看到正确的行为。