Documentation

Returns a multiplexer from a connection, listen for different database notification channels using that connection.

This function also spawns a thread that keeps relaying the messages from the database to the multiplexer's listeners

To listen on channels *chat*

  import Protolude
  import PostgRESTWS.HasqlBroadcast
  import PostgRESTWS.Broadcast
  import Hasql.Connection

  main = do
   conOrError <- H.acquire "postgres:/localhosttest_database"
   let con = either (panic . show) id conOrError :: Connection
   multi <- newHasqlBroadcaster con

   onMessage multi "chat" (ch ->
     forever $ fmap print (atomically $ readTChan ch)
  

Returns a multiplexer from a connection URI or an error message on the left case This function also spawns a thread that keeps relaying the messages from the database to the multiplexer's listeners

Acquire a connection using the provided settings encoded according to the PostgreSQL format.

Reads the messages from the producer and relays them to the active listeners in their respective channels.

Opens a thread that relays messages from the producer thread to the channels forever