I would personally prefer a style with explicit co...

# coroutines

[elizarov]

I would personally prefer a style with explicit concurrency. That is, by default I'd assume I want to process all observed values sequentially (that is what suspending for in Kotlin does), but if I really need to run concurrent processing for each value, then I'd explicitly express it with something like for (v in observable) go { doSomethingWith(v) } where go{...} is some kind of coroutine builder that runs a separate coroutine (in a potentially multi-threaded pool)