如何将rxJava2的可观察转换为可执行?

我有可观察的流,我想把它转换为Comppletable,我该怎么做?


答案 1

流利的方法是使用。Observable.ignoreElements()

Observable.just(1, 2, 3)
.ignoreElements()

如果需要,请将其转换回来。toObservable


答案 2

您可以执行如下操作。

Observable<Integer> observable = Observable.just(1, 2, 3);
Completable completable = Completable.fromObservable(observable);

与在可观察量上一样,您必须订阅 才能启动包装的异步进程。completableObservable

有关该方法的 Java 文档,请参阅此处的更多详细信息


推荐