I am implementing a proof-of-concept implementation of Rx in pure Kotlin using coroutines. In 20 minutes I've made a surprising amount of progress, and already implemented
subscribeOn()
,
observeOn()
,
map()
, and
filter()
. This is feeling too easy so can you guys offer extra sets of eyes? I must be missing something.