arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / NoneTerminatedQueue / dequeueChunk1
dequeueChunk1
abstract suspend fun dequeueChunk1(maxSize: Int): Option<Chunk<A>>
Dequeues one Chunk[A] with no more than maxSize elements. Completes once one is ready.