Is there something analogous to observable.create ...

# coroutines

[Amanjeet Singh]

Is there something analogous to observable.create for Coroutines I found a way through channels just want to dug upon any different ways?

[gildor]

For which abstraction? Flow?

[Zach Klippenstein (he/him) [MOD]]

The closest analog is flow { } and channelFlow { }, which create cold `Flow`s. For channels, there’s CoroutineScope.produce { } (although channels are hot, so that’s a bit different than Observable.create).

[Zach Klippenstein (he/him) [MOD]]

Use flow if you’re emitting from a single context, use channelFlow if you need to emit from other coroutines, or from a regular callback.

[Zach Klippenstein (he/him) [MOD]]

See https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/callback-flow.html

[Amanjeet Singh]

Hey @Zach Klippenstein (he/him) [MOD] thanks will look into this 🙂