arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / NoneTerminatedQueue
NoneTerminatedQueue
interface ~~NoneTerminatedQueue~~<A> : Enqueue<Option<A>>, Dequeue1<Option<A>>, Dequeue<A>
Deprecated: Stream is deprecated in favor of Flow. Use Channel
Functions
| dequeueChunk1 | Dequeues one Chunk[A] with no more than maxSize elements. Completes once one is ready.abstract suspend fun dequeueChunk1(maxSize: Int): Option<Chunk<A>> |
| tryDequeueChunk1 | 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.abstract suspend fun tryDequeueChunk1(maxSize: Int): Option<Chunk<A>> |