| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
PostgRESTWS.HasqlBroadcast
- newHasqlBroadcaster :: Connection -> IO Multiplexer
- acquire :: Settings -> IO (Either ConnectionError Connection)
- relayMessages :: Multiplexer -> IO ()
- relayMessagesForever :: Multiplexer -> IO ThreadId
Documentation
acquire :: Settings -> IO (Either ConnectionError Connection) #
Acquire a connection using the provided settings encoded according to the PostgreSQL format.
relayMessages :: Multiplexer -> IO () Source #
Reads the messages from the producer and relays them to the active listeners in their respective channels.
relayMessagesForever :: Multiplexer -> IO ThreadId Source #
Opens a thread that relays messages from the producer thread to the channels forever