Actually i wonder how replayCache and extraBufferCapacity work , i have also read this answer . but i want to understand how they work together in code and how we get output .

I have a wrapped an external optimization library in a callbackFlow in my quarkus-kotlin backend. Now I want to push updates to my frontend, but since updates from this library arrive quite frequently (at least during the first processing steps), it makes sense to limit the update frequency to save bandwidth.

Flow’s onEach documentation says:

Flow’s onEach documentation says:

Suppose I have getPeople(): List<Person> and getStudent(ssn: String): Student