Am I correct in that the only difference between `flow { }` and `channelFlow { }` is that the latter...

# coroutines

[diesieben07]

Am I correct in that the only difference between flow { } and channelFlow { } is that the latter is "threadsafe", meaning you can switch dispatcher inside the suspending block? Or is there something else?

[octylFractal]

back pressure also differs, since there is a channel between the sender/emitter and consumer

[diesieben07]

Okay, what does that mean exactly? I understand the concept of backpressure, but how do the two differ in this regard?

[Adam Powell]

It means that send returns when the value handoff is complete, contrasted with emit that returns after the downstream collector is done processing it

[diesieben07]

I see. So it would depend on what kind of channel you have "in between", right? If it's a zero-capacity one you effectively have the same as with emit, otherwise you can buffer N elements before you need to wait for the collector.

[octylFractal]

yes, and by default it buffers, but you can use buffer to change that

[diesieben07]

Thanks to both of you, that clears it up!

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

If it’s a zero-capacity one you effectively have the same as with emit

Not quite – offer still returns as soon as the handoff is complete, which, depending on which dispatcher the downstream is running on, may be before the downstream actually finishes processing that item.

[diesieben07]

So say the downstream is doing some long-running operation after receiving each value.
With emit upstream would wait for that operation, with channels it would compute the next element, which would then have to wait for downstream (for the next handoff). Right?

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

exactly

[diesieben07]

Thank you

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

but relying on those semantics can make for brittle code – e.g. nothing’s stopping a downstream consumer from putting a channel in the mix. if you actually need synchronization, and not just backpressure, better to synchronize explicitly

[diesieben07]

Yes, obviously. I was just trying to understand the difference here