arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Dequeue / dequeueChunk
dequeueChunk
abstract fun dequeueChunk(maxSize: Int): Stream<A>
Dequeues elements from the queue, ensuring elements are dequeued in chunks not exceeding maxSize.