If I have a flow being read by 2 collectors, the e...

# coroutines

[sbyrne]

If I have a flow being read by 2 collectors, the emitter goes as fast as the faster collector, and everything gets buffered until the slower collector reads it. How do I limit that buffer so I get backpressure from the slowest collector?

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

How is your flow created?

[sbyrne]

flow { while(true) { emit( calcNextValue() ) } }

[sbyrne]

Oh, I did not realize that emit() is called independently for each collector. Flow is not what I want.

[sbyrne]

My question is nonsensical I guess.

[Dominaezzz]

You can use produceIn(...) and consume it once as a channel.