We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
buffer(duration)
To make Kotlin Flow more suitable for a wide range of tasks, I suggest to add an buffer(Duration) function like in Reactor.
buffer(Duration)
Collect incoming values into multiple List buffers that will be emitted by the returned Flow every bufferingTimespan.
bufferingTimespan
fun <T> Flux<T>.buffer(bufferingTimespan: Duration): Flow<List<T>>
Consider to also implement:
Flux<List<T>> buffer(Duration bufferingTimespan, Duration openBufferEvery)
The text was updated successfully, but these errors were encountered:
It looks like a duplicate of #1302. Please, take a look.
Sorry, something went wrong.
@elizarov Yes, it is a duplicate.
No branches or pull requests
To make Kotlin Flow more suitable for a wide range of tasks, I suggest to add an
buffer(Duration)
function like in Reactor.Description
Collect incoming values into multiple List buffers that will be emitted by the returned Flow every
bufferingTimespan
.Signature
Consider to also implement:
The text was updated successfully, but these errors were encountered: