IxQueue.Aff

newtype IOQueues input output

Constructors

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

new :: forall output input. Effect (IOQueues input output)

newtype IOQueueKey

newKey :: Effect IOQueueKey

callAsync :: forall output input. IOQueueKey -> IOQueues input output -> input -> Aff output

Invoke the queue in Aff

callAsyncEff :: forall output input. IOQueueKey -> IOQueues input output -> Handler output -> input -> Effect Unit

Invoke the queue in Eff

registerSync :: forall output input. IOQueues input output -> (input -> Effect output) -> Effect IOQueueKey

For binding the receiver

registerSyncOnce :: forall output input. IOQueues input output -> (input -> Effect output) -> Effect IOQueueKey

Bind a receiver only once