arrow-fx-coroutines / arrow.fx.coroutines.stream.concurrent
||Provides the ability to dequeue chunks of elements from a
Queue as streams.
||Provides the ability to dequeue individual elements from a
||Provides the ability to enqueue elements to a
interface ~~NoneTerminatedQueue~~<A> :
||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> :
||Pure holder of a single value of type
A that can be read in the effect
||Pure holder of a single atomic value of type
A that can be both read and updated. Composes Signal and Atomic together to make an signalling atomic value.
class ~~SignallingAtomic~~<A> :
Extensions for External Classes