arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Queue / 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?
✖