kmath-coroutines/space.kscience.kmath.streaming/chunked

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