Queue.Internal

type Handler eff a = a -> Eff eff Unit

newtype Queue eff a

Constructors

• Queue (Ref (Either (Array a) (Array (Handler eff a))))

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

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

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

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

onceQueue :: forall a eff. Queue (ref :: REF | eff) a -> Handler (ref :: REF | eff) a -> Eff (ref :: REF | eff) Unit

Treat this as the only handler, and on the next input, clear all handlers.

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

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

delQueue :: forall a eff. Queue (ref :: REF | eff) a -> Eff (ref :: REF | eff) Unit

Removes the registered callbacks, if any.