Utils.Queue

Definitions

data Queue : Type -> Type

Totality: total
Visibility: export
Constructor: 

Q : Mutex -> IORef (Seq (QueueEvent a)) -> Queue a

mk_queue : HasIO io => io (Queue a)

Visibility: export

recv : HasIO io => Queue a -> io a

  receive a message, if empty, block until there is one

Visibility: export

recv' : HasIO io => Queue a -> io (Maybe a)

  receive a message, if empty, returns nothing

Visibility: export

recv_all : HasIO io => Queue a -> io (List a)

  receive all the messages waiting to be processed

Visibility: export

signal : HasIO io => Queue a -> a -> io ()

  send a message to one of the receiver

Visibility: export

broadcast : HasIO io => Queue a -> a -> io ()

  send a message to all the receivers

Visibility: export