If you start with reactive stream spec interfaces http://www.reactive-streams.org/ and throw in

kotlinx-coroutines-reactive

module, then actually writing all the Rx operators becomes quite a trivial endeavor. See here for details: https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/coroutines-guide-reactive.md#operators

elizarov: intriguing I may give this a glance