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 #

testChannelLimit :: HasCallStack => App () Source #

data EventWebSocket Source #

createEventsWebSocket :: (HasCallStack, MakesValue uid) => uid -> String -> Codensity App EventWebSocket Source #

ackFullSync :: HasCallStack => EventWebSocket -> App () Source #

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

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

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

assertNoEvent :: HasCallStack => EventWebSocket -> App () Source #

consumeAllEvents :: EventWebSocket -> App () Source #