PostgRESTWS.Broadcast

Documentation

data Multiplexer

data Message

Constructors

Message

Fields

• channel :: ByteString
• payload :: ByteString

Instances

Eq Message

Methods

(==) :: Message -> Message -> Bool

(/=) :: Message -> Message -> Bool

Show Message

Methods

showsPrec :: Int -> Message -> ShowS

show :: Message -> String

showList :: [Message] -> ShowS

data SourceCommands

Constructors

Open ByteString

Close ByteString

Instances

Show SourceCommands

Methods

showsPrec :: Int -> SourceCommands -> ShowS

show :: SourceCommands -> String

showList :: [SourceCommands] -> ShowS

newMultiplexer :: (TQueue SourceCommands -> TQueue Message -> IO a) -> (Either SomeException a -> IO ()) -> IO Multiplexer

onMessage :: Multiplexer -> ByteString -> (TChan Message -> IO ()) -> IO ()

relayMessages :: Multiplexer -> IO ()

relayMessagesForever :: Multiplexer -> IO ThreadId

openChannelProducer :: Multiplexer -> ByteString -> STM ()

closeChannelProducer :: Multiplexer -> ByteString -> STM ()

readTQueue :: TQueue a -> STM a

Read the next value from the TQueue.

writeTQueue :: TQueue a -> a -> STM ()

Write a value to a TQueue.

readTChan :: TChan a -> STM a

Read the next value from the TChan.