example - ¿Cómo convertir el Observable de rxJava2 a Completable?
rxjs (4)
Tengo un flujo observable y quiero convertirlo en Completable, ¿cómo podría hacerlo?
Podría utilizar Completable.fromObservable (xx) . Eso funciona bien en mi proyecto.
Puedes hacer algo como abajo.
Observable<Integer> observable = Observable.just(1, 2, 3);
Completable completable = Completable.fromObservable(observable);
Como en un Observable, tendrá que suscribirse a la completable para iniciar el proceso asíncrono que el Observable ajusta.
Se pueden encontrar más detalles aquí en el documento de Java para el método .
Utilice Completable.merge (YourObservable () ...
La forma fluida es usar Observable.ignoreElements() .
Observable.just(1, 2, 3)
.ignoreElements()
Convertir de nuevo a través de toObservable si es necesario.