| Portability | portable |
|---|---|
| Stability | experimental |
| Maintainer | k.pierre.k@gmail.com |
| Safe Haskell | Safe-Infered |
Network.XMPP.Concurrent
Description
Concurrent actions over single IO channel
- data Thread
- type XmppThreadT a = ReaderT Thread IO a
- runThreaded :: XmppThreadT () -> XmppStateT ()
- readChanS :: XmppThreadT Stanza
- writeChanS :: Stanza -> XmppThreadT ()
- withNewThread :: XmppThreadT () -> XmppThreadT ThreadId
- loop :: XmppThreadT () -> XmppThreadT ()
- waitFor :: (Stanza -> Bool) -> XmppThreadT Stanza
Documentation
type XmppThreadT a = ReaderT Thread IO aSource
runThreaded :: XmppThreadT () -> XmppStateT ()Source
Runs thread in XmppState monad
writeChanS :: Stanza -> XmppThreadT ()Source
withNewThread :: XmppThreadT () -> XmppThreadT ThreadIdSource
Runs specified action in parallel
loop :: XmppThreadT () -> XmppThreadT ()Source
Turns action into infinite loop