java - RxJava 合并 Flowable 和 Completable

Question

我有一个 Flowable，它不断地发出项目并且从不调用 onError 或 onComplete。现在我有一个 Completable，我想将它与这个 Flowable 合并，这样当 Completable 完成 Flowable调用 onComplete。我不能直接更改给我的 Flowable 对象。

我遇到的一个问题是我会在 Flowable 上使用 takeUntil 但是 Flowable 可能会在任何时候停止发射项目并且我仍然希望 Completable 能够调用 onComplete。

更新:因为我们可以执行Completable.toFlowable()，所以我们能够合并两个Flowables。问题是当一个完成时，我仍然找不到一种方法来完成这两个。

Answer 1

正如您所指出的，您无法更改原始 Flowable 本身，因此它不会发出 onComplete。但是，您可以通过执行以下操作(伪代码)使生成的 Flowable 发出它:

val f: Flowable = ...
val c: Completable = ...
val r: Flowable = f.materialize().mergeWith(c.materialize()).dematerialize()