chunked

fun <T> Flow<T>.chunked(bufferSize: Int, bufferFactory: BufferFactory<T>): Flow<Buffer<T>>
Content copied to clipboard

Collect incoming flow into fixed size chunks

fun Flow<Double>.chunked(bufferSize: Int): Flow<DoubleBuffer>
Content copied to clipboard

Specialized flow chunker for real buffer