Module

IxQueue.Aff

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

#IOQueues Source

newtype IOQueues eff input output

Constructors

IOQueues { input :: IxQueue (read :: READ) eff input, output :: IxQueue (write :: WRITE) eff output }

#newIOQueues Source

newIOQueues :: forall output input eff. Eff (ref :: REF | eff) (IOQueues (ref :: REF | eff) input output)

#IOQueueKey Source

newtype IOQueueKey

#newIOQueueKey Source

newIOQueueKey :: forall eff. Eff (uuid :: GENUUID | eff) IOQueueKey

#callAsync Source

callAsync :: forall output input eff. IOQueueKey -> IOQueues (ref :: REF | eff) input output -> input -> Aff (ref :: REF | eff) output

Invoke the queue in Aff

#callAsyncEff Source

callAsyncEff :: forall output input eff. IOQueueKey -> IOQueues (ref :: REF | eff) input output -> (output -> Eff (ref :: REF | eff) Unit) -> input -> Eff (ref :: REF | eff) Unit

Invoke the queue in Eff

#registerSync Source

registerSync :: forall output input eff. IOQueues (ref :: REF, uuid :: GENUUID | eff) input output -> (input -> Eff (ref :: REF, uuid :: GENUUID | eff) output) -> Eff (ref :: REF, uuid :: GENUUID | eff) IOQueueKey

For binding the receiver

#registerSyncOnce Source

registerSyncOnce :: forall output input eff. IOQueues (ref :: REF, uuid :: GENUUID | eff) input output -> (input -> Eff (ref :: REF, uuid :: GENUUID | eff) output) -> Eff (ref :: REF, uuid :: GENUUID | eff) IOQueueKey

Bind a receiver only once

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