A modern programming language that makes developers happier.

kotlinlang

Is there a rxjava `buffer` equivalent in Flow? flow.buffer is not the same behavior from what I see, i.e. I want to collect upstream emits into some buffer, and only emit the buffer when its full/time elapses etc

Perhaps windowed or chunked?
<https://kotlinlang.org/api/latest/jvm/stdlib/kotlin.collections/windowed.html>

<https://github.com/Kotlin/kotlinx.coroutines/issues/1290>

btw any reason for changing the name? I mean reactive streams called this buffer since ever

The reason is to be consistent with existing kotlin operators

There is a PR with this operator, you can try to use it:
<https://github.com/Kotlin/kotlinx.coroutines/pull/1558>