A modern programming language that makes developers happier.

kotlinlang

I'm thinking about building a flow around a kafka consumer; problem is that the consumer only allows me to call its methods from a single thread. I was able to implement this using coroutines fired by a single-threaded dispatcher and communicating via channels. But for a Flow-centered solution I build a flow using the `flow{}` builder, can I somehow guarantee that the code in the `flow{}` will run inside a specific dispatcher but the code that collects the results sent by `emit()`will run in a less-restricted dispatcher?

`.flowOn()` affects the dispatcher upstream and is what you need
<https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/flow-on.html>