BlockingChain

interface BlockingChain<out T> : Chain<T>

A chain with blocking generator that could be used without suspension

Functions

collect
Link copied to clipboard
common
open suspend override fun collect(collector: FlowCollector<T>)
fork
Link copied to clipboard
common
abstract suspend override fun fork(): BlockingChain<T>
Create a copy of current chain state.
next
Link copied to clipboard
common
open suspend override fun next(): T
Generate next value, changing state if needed
nextBlocking
Link copied to clipboard
common
abstract fun nextBlocking(): T
Get the next value without concurrency support.

Inheritors

BlockingBufferChain
Link copied to clipboard

Extensions

nextBufferBlocking
Link copied to clipboard
common
inline fun <T : Any> BlockingChain<T>.nextBufferBlocking(size: Int): Buffer<T>

Sources

common source
Link copied to clipboard