arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent / Enqueue
Enqueue
interface ~~Enqueue~~<A>
Deprecated: Stream is deprecated in favor of Flow. Use SendChannel
Provides the ability to enqueue elements to a Queue.
Functions
| enqueue | Enqueues each element of the input stream to this queue by calling enqueue1 on each element.open fun enqueue(): Pipe<A, Unit> |
| enqueue1 | Enqueues one element to this Queue. If the queue is full this waits until queue has space.abstract suspend fun enqueue1(a: A): Unit |
| tryOffer1 | Offers one element to this Queue.abstract fun tryOffer1(a: A): Boolean |
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> |