package unsafe
- Alphabetic
- Public
- Protected
Type Members
- trait BoundedQueue[F[_], A] extends Queue[F, A] with BoundedQueueSink[F, A]
A Queue which supports a side-effecting variant of
tryOffer
, allowing impure code to add elements to the queue without having to indirect through something like Dispatcher.A Queue which supports a side-effecting variant of
tryOffer
, allowing impure code to add elements to the queue without having to indirect through something like Dispatcher. Note that a side-effecting variant ofoffer
is impossible without hard-blocking a thread (when the queue is full), and thus is not supported by this API. For a variant of the same queue which supports a side-effectingoffer
, see UnboundedQueue.- See also
- trait BoundedQueueSink[F[_], A] extends QueueSink[F, A]
- trait UnboundedQueue[F[_], A] extends Queue[F, A] with BoundedQueue[F, A] with UnboundedQueueSink[F, A]
A Queue which supports a side-effecting variant of
offer
, allowing impure code to add elements to the queue without having to indirect through something like Dispatcher.A Queue which supports a side-effecting variant of
offer
, allowing impure code to add elements to the queue without having to indirect through something like Dispatcher.- See also
- trait UnboundedQueueSink[F[_], A] extends QueueSink[F, A] with BoundedQueueSink[F, A]
Value Members
- object BoundedQueue
- object BoundedQueueSink
- object UnboundedQueue
- object UnboundedQueueSink