Concurrent.BoundedQueue.Sync

new :: forall a. Int -> Effect (BoundedQueue a)

Synchronously creates a new BoundedQueue with the given capacity.

isEmpty :: forall a. BoundedQueue a -> Effect Boolean

Synchronously checks whether the given queue is empty. Never blocks.

tryRead :: forall a. BoundedQueue a -> Effect (Maybe a)

Synchronously attempts to read an element from the given queue. If the queue is empty, or there is a concurrent reader, returns Nothing.

tryWrite :: forall a. BoundedQueue a -> a -> Effect Boolean

Attempts to write an element into the given queue. If the queue is full, or there is a concurrent writer, returns false otherwise true.

newtype BoundedQueue a