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?

How is your flow created?

You can use

produceIn(...)

and consume it once as a channel.