Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- enqueue :: Text -> Value a -> [a] -> Session ()
- withDequeue :: Text -> Connection -> Value a -> Int -> (Session [a] -> Session b) -> IO b
- withDequeueWith :: WithNotifyHandlers -> Text -> Connection -> Value a -> Int -> (Session [a] -> Session b) -> IO b
Documentation
:: Text | Notification channel name. Any valid PostgreSQL identifier |
-> Value a | Payload encoder |
-> [a] | List of payloads to enqueue |
-> Session () |
Enqueue a payload send a notification on the specified channel.
:: WithNotifyHandlers | Event handlers for events that occur as |
-> Text | Notification channel name. Any valid PostgreSQL identifier |
-> Connection | Connection |
-> Value a | Payload decoder |
-> Int | Batch count |
-> (Session [a] -> Session b) | Transaction runner |
-> IO b |