chunked

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

Collect incoming flow into fixed size chunks

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

Specialized flow chunker for real buffer