IxQueue.IOQueues

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

callAsync :: forall output input. String -> IOQueues IxQueue input output -> input -> Aff output

Invoke the queue in Aff

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

Invoke the queue in Eff

registerSync :: forall output input. String -> IOQueues IxQueue input output -> (input -> Effect output) -> Effect Unit

For binding the receiver

registerSyncOnce :: forall output input. String -> IOQueues IxQueue input output -> (input -> Effect output) -> Effect Unit

Bind a receiver only once

newtype IOQueues q input output

Represents an asynchronously invokable function input -> Aff output

Constructors

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