BufferChain

interface BufferChain<out T> : Chain<T>
Content copied to clipboard

Functions

collect
Link copied to clipboard
common
open suspend override fun collect(collector: FlowCollector<T>)
Content copied to clipboard
fork
Link copied to clipboard
common
abstract suspend override fun fork(): BufferChain<T>
Content copied to clipboard
Create a copy of current chain state.
next
Link copied to clipboard
common
abstract suspend fun next(): T
Content copied to clipboard
Generate next value, changing state if needed
nextBuffer
Link copied to clipboard
common
abstract suspend fun nextBuffer(size: Int): Buffer<T>
Content copied to clipboard

Inheritors

BlockingBufferChain
Link copied to clipboard