Hoogle Search
Within LTS Haskell 24.52 (ghc-9.10.3)
Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.
type
UnregisterCallbacksAction = IO ()hedis Database.Redis An action that when executed will unregister the callbacks. It is returned from addChannels or addChannelsAndWait and typically you would use it in bracket to guarantee that you unsubscribe from channels. For example, if you are using websockets to distribute messages to clients, you could use something such as:
websocketConn <- Network.WebSockets.acceptRequest pending let mycallback msg = Network.WebSockets.sendTextData websocketConn msg bracket (addChannelsAndWait ctrl [("hello", mycallback)] []) id $ const $ do {- loop here calling Network.WebSockets.receiveData -}flushall :: RedisCtx m f => m (f Status)hedis Database.Redis No documentation available.
hgetall :: RedisCtx m f => ByteString -> m (f [(ByteString, ByteString)])hedis Database.Redis No documentation available.
smallestPendingMessageId :: XPendingSummaryResponse -> ByteStringhedis Database.Redis No documentation available.
type
MessageCallback = ByteString -> IO ()hedis Database.Redis.Sentinel A handler for a message from a subscribed channel. The callback is passed the message content. Messages are processed synchronously in the receiving thread, so if the callback takes a long time it will block other callbacks and other messages from being received. If you need to move long-running work to a different thread, we suggest you use TBQueue with a reasonable bound, so that if messages are arriving faster than you can process them, you do eventually block. If the callback throws an exception, the exception will be thrown from pubSubForever which will cause the entire Redis connection for all subscriptions to be closed. As long as you call pubSubForever in a loop you will reconnect to your subscribed channels, but you should probably add an exception handler to each callback to prevent this.
type
PMessageCallback = RedisChannel -> ByteString -> IO ()hedis Database.Redis.Sentinel A handler for a message from a psubscribed channel. The callback is passed the channel the message was sent on plus the message content. Similar to MessageCallback, callbacks are executed synchronously and any exceptions are rethrown from pubSubForever.
type
UnregisterCallbacksAction = IO ()hedis Database.Redis.Sentinel An action that when executed will unregister the callbacks. It is returned from addChannels or addChannelsAndWait and typically you would use it in bracket to guarantee that you unsubscribe from channels. For example, if you are using websockets to distribute messages to clients, you could use something such as:
websocketConn <- Network.WebSockets.acceptRequest pending let mycallback msg = Network.WebSockets.sendTextData websocketConn msg bracket (addChannelsAndWait ctrl [("hello", mycallback)] []) id $ const $ do {- loop here calling Network.WebSockets.receiveData -}flushall :: RedisCtx m f => m (f Status)hedis Database.Redis.Sentinel No documentation available.
hgetall :: RedisCtx m f => ByteString -> m (f [(ByteString, ByteString)])hedis Database.Redis.Sentinel No documentation available.
smallestPendingMessageId :: XPendingSummaryResponse -> ByteStringhedis Database.Redis.Sentinel No documentation available.