I have Observable stream, and I want to convert it to Completable, how I could do that?
相关问题
- Delete Messages from a Topic in Apache Kafka
- Jackson Deserialization not calling deserialize on
- How to maintain order of key-value in DataFrame sa
- StackExchange API - Deserialize Date in JSON Respo
- Difference between Types.INTEGER and Types.NULL in
The fluent way is to use
Observable.ignoreElements()
.Convert it back via
toObservable
if needed.You can do something like below.
Like on an Observable, you will have to subscribe to the
completable
to start the asynchronous process thatObservable
wraps.More details can be found here in the Java doc for the method.
You could use Completable.fromObservable(xx). That is worked fine on my project.
Use Completable.merge(YourObservable()...