arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Dequeue
Dequeue
interface ~~Dequeue~~<A>
Deprecated: Stream is deprecated in favor of Flow. Use ReceiveChannel
Provides the ability to dequeue chunks of elements from a Queue as streams.
Functions
| dequeue | Dequeues elements from the queue.open fun dequeue(): Stream<A> |
| dequeueBatch | Provides a pipe that converts a stream of batch sizes in to a stream of elements by dequeuing batches of the specified size.abstract fun dequeueBatch(): Pipe<Int, A> |
| dequeueChunk | Dequeues elements from the queue, ensuring elements are dequeued in chunks not exceeding maxSize.abstract fun dequeueChunk(maxSize: Int): Stream<A> |
Inheritors
| NoneTerminatedQueue | interface ~~NoneTerminatedQueue~~<A> : Enqueue<Option<A>>, Dequeue1<Option<A>>, Dequeue<A> |
| Queue | A queue of elements. Operations are all nonblocking in their implementations, but may be ‘semantically’ blocking. For instance, a queue may have a bound on its size, in which case enqueuing may block (be delayed asynchronously) until there is an offsetting dequeue.interface ~~Queue~~<A> : Enqueue<A>, Dequeue1<A>, Dequeue<A> |