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

chunked

fun <T> Flow<T>.chunked(bufferSize: Int, bufferFactory: BufferFactory<T>): Flow<Buffer<T>>(source)

Collect incoming flow into fixed size chunks

fun Flow<Double>.chunked(bufferSize: Int): Flow<DoubleBuffer>(source)

Specialized flow chunker for real buffer