arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / dequeueChunk1

dequeueChunk1

abstract suspend fun dequeueChunk1(maxSize: Int): Chunk<A>

Dequeues one Chunk[A] with no more than maxSize elements. Completes once one is ready.

Do you like Arrow?

Arrow Org
<