arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / NoneTerminatedQueue / tryDequeueChunk1

tryDequeueChunk1

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

Tries to dequeue a single chunk of no more than max size elements. Unlike dequeueChunk1, this method does not semantically block until a chunk is available - instead, None is returned immediately.