Queue.One

newtype Queue (rw :: Row SCOPE) a

Constructors

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

Instances

• QueueScope Queue

new :: forall a. Effect (Queue (read :: READ, write :: WRITE) a)

put :: forall a rw. Queue (write :: WRITE | rw) a -> a -> Effect Unit

putMany :: forall t a rw. Traversable t => Queue (write :: WRITE | rw) a -> NonEmpty t a -> Effect Unit

on :: forall a rw. Queue (read :: READ | rw) a -> Handler a -> Effect Unit

once :: forall a rw. Queue (read :: READ | rw) a -> Handler a -> Effect Unit

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

draw :: forall a rw. Queue (read :: READ | rw) a -> Aff a

take :: forall a rw. Queue (write :: WRITE | rw) a -> Effect (Array a)

read :: forall a rw. Queue rw a -> Effect (Array a)

del :: forall a rw. Queue (read :: READ | rw) a -> Effect Unit

Removes the registered callbacks, if any.

drain :: forall a rw. Queue (read :: READ | rw) a -> Effect Unit

data WRITE :: SCOPE

data READ :: SCOPE

type Handler a = a -> Effect Unit

class QueueScope (q :: Row SCOPE -> Type -> Type) 

data SCOPE :: Type