Is there a rxjava `buffer` equivalent in Flow? flow.buffer is not the same behavior from what I see,...

# coroutines

[ursus]

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

[Richard Gomez]

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

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

[ursus]

open, so .. no, bummer

[ursus]

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

[gildor]

The reason is to be consistent with existing kotlin operators

[gildor]

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