Documentation

testConsumeEventsOneWebSocket :: HasCallStack => App () Source #

testConsumeEventsForDifferentUsers :: HasCallStack => App () Source #

testConsumeEventsWhileHavingLegacyClients :: HasCallStack => App () Source #

testConsumeEventsAcks :: HasCallStack => App () Source #

testConsumeEventsMultipleAcks :: HasCallStack => App () Source #

testConsumeEventsAckNewEventWithoutAckingOldOne :: HasCallStack => App () Source #

testEventsDeadLettered :: HasCallStack => App () Source #

testTransientEventsDoNotTriggerDeadLetters :: HasCallStack => App () Source #

testTransientEvents :: HasCallStack => App () Source #

withEventsWebSockets :: forall uid a. (HasCallStack, MakesValue uid) => [(uid, String)] -> ([(TChan Value, TChan Value)] -> App a) -> App a Source #

withEventsWebSocket :: (HasCallStack, MakesValue uid) => uid -> String -> (TChan Value -> TChan Value -> App a) -> App a Source #

sendMsg :: HasCallStack => TChan Value -> Value -> App () Source #

ackFullSync :: HasCallStack => TChan Value -> App () Source #

ackEvent :: HasCallStack => TChan Value -> Value -> App () Source #

sendAck :: HasCallStack => TChan Value -> Value -> Bool -> App () Source #

assertEvent :: HasCallStack => TChan Value -> (HasCallStack => Value -> App a) -> App a Source #

assertNoEvent :: HasCallStack => TChan Value -> App () Source #

consumeAllEvents :: TChan Value -> TChan Value -> App () Source #

eventsWebSocket :: MakesValue user => user -> String -> TChan Value -> TChan Value -> MVar () -> App (Async ()) Source #