Queue

newtype Queue a

newQueue :: forall a eff. Eff (channel :: CHANNEL, ref :: REF | eff) (Queue a)

putQueue :: forall a eff. Queue a -> a -> Eff (channel :: CHANNEL, ref :: REF | eff) Unit

Signal the listener with a value - note that there can be any number of writers to the queue.

putManyQueue :: forall a eff. Queue a -> Array a -> Eff (channel :: CHANNEL, ref :: REF | eff) Unit

onQueue :: forall a eff. Queue a -> (a -> Eff (channel :: CHANNEL, ref :: REF | eff) Unit) -> Eff (channel :: CHANNEL, ref :: REF | eff) Unit

There should only be one listener at a time per queue - multiple readers would cause a race condition.

readQueue :: forall a eff. Queue a -> Eff (ref :: REF | eff) (Array a)

Read the entities in the queue without triggering the onQueue callback.

takeQueue :: forall a eff. Queue a -> Eff (ref :: REF | eff) (Array a)

Take the entities out of the queue without triggering the onQueue callback.