Probably kotlinx-coroutines-reactor needs a conver...
# coroutines
g
Probably kotlinx-coroutines-reactor needs a converter of flux to a channel, so you can consume items using suspend function. Now there is only converter from coroutines to reactor https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-reactor RxJava integration have such adapters https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive/kotlinx-coroutines-rx2