如何将rxJava2的Observable转换为Completable？

Question

我有Observable流,我想将它转换为Completable,我怎么能这样做？

Answer 1

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

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

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

Answer 2

你可以做下面这样的事情.

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

就像在Observable上一样,您必须订阅completable以启动Observable包装的异步进程.

有关该方法的Java文档中可以找到更多详细信息.