| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Matterhorn.Connection
Synopsis
- connectWebsockets :: MH ()
- ignoreThreadKilled :: AsyncException -> IO ()
- processWebsocketActions :: ChatState -> MMWebSocket -> Int64 -> HashMap ChannelId (Max UTCTime) -> IO ()
- handleTimeout :: (LogCategory -> Text -> IO ()) -> Int -> ChatState -> MMWebSocketTimeoutException -> IO ()
- handleError :: (LogCategory -> Text -> IO ()) -> Int -> ChatState -> SomeException -> IO ()
- reconnectAfter :: Int -> ChatState -> IO ()
Documentation
connectWebsockets :: MH () Source #
ignoreThreadKilled :: AsyncException -> IO () Source #
processWebsocketActions :: ChatState -> MMWebSocket -> Int64 -> HashMap ChannelId (Max UTCTime) -> IO () Source #
Take websocket actions from the websocket action channel in the ChatState and send them to the server over the websocket.
Takes and propagates the action sequence number which is incremented for each successful send.
Keeps and propagates a map of channel id to last user_typing notification send time so that the new user_typing actions are throttled to be send only once in two seconds.
handleTimeout :: (LogCategory -> Text -> IO ()) -> Int -> ChatState -> MMWebSocketTimeoutException -> IO () Source #
handleError :: (LogCategory -> Text -> IO ()) -> Int -> ChatState -> SomeException -> IO () Source #