Portability | non-portable |
---|---|
Stability | experimental |
Safe Haskell | None |
Subscriber side of 'Publish Subscribe'
Documentation
checkSub :: Sub -> Timeout -> SinkR (Maybe a) -> IO (Maybe a)Source
Check for new data:
-
Sub
- The subscriber -
Timeout
- When timeout expires, the function returnsNothing
. Timeout may be -1 - listen eternally, 0 - return immediately, > 0 - timeout in microseconds -
SinkR
- Sink the result stream. Note that the subscription header, i.e. a message segment containing a comma-separated list of the topics, to which the data belong, is dropped.