If you start with reactive stream spec interfaces ...

# rx

[elizarov]

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

[thomasnield]

elizarov: intriguing I may give this a glance