kmath-coroutines/space.kscience.kmath.streaming

Package-level declarations

Types

class RingBuffer<T>(buffer: MutableBuffer<T?>, startIndex: Int = 0, size: Int = 0) : Buffer<T>

Thread-safe ring buffer

Create a Flow from buffer

Specialized flow chunker for real buffer

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

Collect incoming flow into fixed size chunks

Flat map a Flow of Buffer into continuous Flow of elements

Map a flow to a moving window buffer. The window step is one. To get different steps, one could use skip operation.