Roman Elizarov If it is easy for you can you provide an example of how you would implement buffertimeout with kotlin flows?

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-