arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Dequeue / dequeueBatch
dequeueBatch
abstract fun dequeueBatch(): Pipe<Int, A>
Provides a pipe that converts a stream of batch sizes in to a stream of elements by dequeuing batches of the specified size.