Module

IxQueue

Package: purescript-queue
Repository: athanclark/purescript-queue

#IxQueue Source

newtype IxQueue (rw :: Row SCOPE) (eff :: Row Effect) a

Constructors

IxQueue { broadcast :: Ref (Array a), individual :: Ref (StrMap (Either (Array a) (a -> Eff eff Unit))) }

#readOnly Source

readOnly :: forall a eff rw. IxQueue (read :: READ | rw) eff a -> IxQueue (read :: READ) eff a

#writeOnly Source

writeOnly :: forall a eff rw. IxQueue (write :: WRITE | rw) eff a -> IxQueue (write :: WRITE) eff a

#allowReading Source

allowReading :: forall a eff rw. IxQueue (write :: WRITE) eff a -> IxQueue (write :: WRITE | rw) eff a

#allowWriting Source

allowWriting :: forall a eff rw. IxQueue (read :: READ) eff a -> IxQueue (read :: READ | rw) eff a

#newIxQueue Source

newIxQueue :: forall a eff. Eff (ref :: REF | eff) (IxQueue (read :: READ, write :: WRITE) (ref :: REF | eff) a)

#putIxQueue Source

putIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> String -> a -> Eff (ref :: REF | eff) Unit

#putManyIxQueue Source

putManyIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> String -> Array a -> Eff (ref :: REF | eff) Unit

#broadcastIxQueue Source

broadcastIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> a -> Eff (ref :: REF | eff) Unit

#broadcastManyIxQueue Source

broadcastManyIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> Array a -> Eff (ref :: REF | eff) Unit

#onIxQueue Source

onIxQueue :: forall rw a eff. IxQueue (read :: READ | rw) (ref :: REF | eff) a -> String -> (a -> Eff (ref :: REF | eff) Unit) -> Eff (ref :: REF | eff) Unit

#onceIxQueue Source

onceIxQueue :: forall rw a eff. IxQueue (read :: READ | rw) (ref :: REF | eff) a -> String -> (a -> Eff (ref :: REF | eff) Unit) -> Eff (ref :: REF | eff) Unit

#readBroadcastIxQueue Source

readBroadcastIxQueue :: forall rw a eff. IxQueue rw (ref :: REF | eff) a -> Eff (ref :: REF | eff) (Array a)

#readIxQueue Source

readIxQueue :: forall rw a eff. IxQueue rw (ref :: REF | eff) a -> String -> Eff (ref :: REF | eff) (Array a)

#takeBroadcastIxQueue Source

takeBroadcastIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> Eff (ref :: REF | eff) (Array a)

#takeIxQueue Source

takeIxQueue :: forall rw a eff. IxQueue (write :: WRITE | rw) (ref :: REF | eff) a -> String -> Eff (ref :: REF | eff) (Array a)

#delIxQueue Source

delIxQueue :: forall rw a eff. IxQueue (read :: READ | rw) (ref :: REF | eff) a -> String -> Eff (ref :: REF | eff) Boolean

Unregisters a handler, returns whether one existed

#clearIxQueue Source

clearIxQueue :: forall rw a eff. IxQueue (read :: READ | rw) (ref :: REF | eff) a -> Eff (ref :: REF | eff) Unit

#drainIxQueue Source

drainIxQueue :: forall rw a eff. IxQueue (read :: READ | rw) (ref :: REF | eff) a -> String -> Eff (ref :: REF | eff) Unit

Re-exports from Queue.Scope

#WRITE Source

data WRITE :: SCOPE

#READ Source

data READ :: SCOPE

#SCOPE Source

data SCOPE :: Type

Modules: IxQueue; IxQueue.Aff; Queue; Queue.Aff; Queue.One; Queue.One.Aff; Queue.Scope