Sparrow.Client.Queue

type SparrowStaticClientQueues initIn initOut = IOQueues initIn (Maybe initOut)

type SparrowClientQueues initIn initOut deltaIn deltaOut = { deltaIn :: Queue (write :: WRITE) deltaIn, deltaOut :: Queue (read :: READ) deltaOut, init :: SparrowStaticClientQueues initIn initOut, onReject :: Queue (read :: READ) Unit, unsubscribe :: Queue (write :: WRITE) Unit }

newSparrowStaticClientQueues :: forall initOut initIn. Effect (SparrowStaticClientQueues initIn initOut)

newSparrowClientQueues :: forall deltaOut deltaIn initOut initIn. Effect (SparrowClientQueues initIn initOut deltaIn deltaOut)

sparrowStaticClientQueues :: forall initOut initIn. SparrowStaticClientQueues initIn initOut -> Client initIn initOut JSONVoid JSONVoid

sparrowClientQueues :: forall deltaOut deltaIn initOut initIn. SparrowClientQueues initIn initOut deltaIn deltaOut -> Client initIn initOut deltaIn deltaOut

callSparrowClientQueues :: forall deltaOut deltaIn initOut initIn. SparrowClientQueues initIn initOut deltaIn deltaOut -> (deltaOut -> Effect Unit) -> initIn -> Aff (Maybe { deltaIn :: deltaIn -> Effect Unit, initOut :: initOut, unsubscribe :: Effect Unit })

Simplified version of calling queues, which doesn't care about unsubscribing

mountSparrowClientQueuesSingleton :: forall deltaOut deltaIn initOut initIn. SparrowClientQueues initIn initOut deltaIn deltaOut -> Queue (write :: WRITE) deltaIn -> Queue (write :: WRITE) initIn -> (deltaOut -> Effect Unit) -> (Maybe initOut -> Effect Unit) -> Effect (Effect Unit)

Be open as long as possible, while disallowing multiple init invocations while a subscription is open. The only way to dismantle is through killing the sub, via the result action