Join Slack
Powered by
<@U0B86L2VA> Here it is. It is for old revision of...
# coroutines
e
elizarov
02/01/2017, 8:39 PM
@adeln
Here it is. It is for old revision of coroutines. Needs cleanup and updating. I hope you can get the idea, though: 1. Iterator over observable:
https://github.com/elizarov/kotlinx.coroutines/blob/asyncRxIterator/kotlinx-coroutines-rx/src/main/kotlin/asyncRxIterator.kt
2. Generator for observable with backpressure support (named
asyncRxGenerate{ ... emit(x) ... }
-- not a good choice)
https://github.com/elizarov/kotlinx.coroutines/blob/asyncRxGenerate/kotlinx-coroutines-rx/src/main/kotlin/asyncRxGenerator.kt
3
Views
Open in Slack
Previous
Next