Is there anyway to make the buffer of the Flow strict? Right now it seems to have the same behavior as channel with +2

What do you mean strict?

@Dominaezzz if I just do flow.buffer(1) the buffer will still perform 3 rounds of whatever is happening before the emit

You can't un-buffer a channel btw.

let me show you an example, hold on a sec 🙂

If you have a pipeline, every coroutine between channels will implicitly act as a buffer of 1. So if you are trying to use backpressure to achieve some precise limit, it’s going to be very brittle even if you can get it to work.

yea I think I realized that what I want is actually channels because the "get10MessagesFromSqs" is pretty much a http-call, so there isn't that much of an "asynchronous delivery behavior" in that