miqbaldc
03/06/2020, 9:32 AMObservable
-> Flow
2. `Completable`/`Single` / `Completable.defer`/`Single.defer`-> suspend fun
/ Deferred
?
3. PublishSubject
-> BroadcastChannel
?
4. Observable.merge
, Observable.compose
, Observable.mergeWith
-> Flow.zip
, Job.join
, x?
5. ObservableTransformer
, `-> ?
6. Flowable.just
-> flowOf
?
7. Flowable.flatMapPublisher
-> Flow.map
the above usecase we found from below references:
1. https://www.slideshare.net/manuelvicnt/coroutines-and-rxjava-an-asynchronicity-comparison
2. https://viseon.ch/blogs/convertRxToCoroutine/index.html
3. https://github.com/epam/CoroutinesExtensions
4. https://github.com/sys1yagi/implementation-of-async-request-with-rxjava2-or-coroutine