zeromq3-haskell 0.1.3 → 0.1.4
raw patch · 3 files changed
+15/−3 lines, 3 files
Files
- README.md +2/−0
- src/System/ZMQ3.hs +12/−2
- zeromq3-haskell.cabal +1/−1
README.md view
@@ -5,6 +5,8 @@ This software currently has *beta* status, i.e. it had seen limited testing. +Version 0.1.4 - Expose 'waitRead' and 'waitWrite'.+ Version 0.1.3 - Deprecated 'Xreq', 'XRep' in favour of 'Dealer' and 'Router' as in libzmq. Fixes to compile and run with GHC 7.4.1.
src/System/ZMQ3.hs view
@@ -59,7 +59,7 @@ -- 'receive' are internally non-blocking and use GHC's I/O manager to block -- calling threads when send or receive would yield EAGAIN. This combined with -- GHC's scalable threading model should relieve client code from the burden--- to do it's own polling. For timeouts please consider 'System.Timeout.timeout'.+-- to do it's own polling. -- -- /Error Handling/ --@@ -170,6 +170,8 @@ , term , socket , close+ , waitRead+ , waitWrite ) where @@ -648,7 +650,15 @@ where testev e = e .&. fromIntegral (pollVal f) /= 0 -waitRead, waitWrite :: Socket a -> IO ()+-- | Wait until data is available for reading from the given Socket.+-- After this function returns, a call to 'receive' will essentially be+-- non-blocking.+waitRead :: Socket a -> IO () waitRead = wait' threadWaitRead pollIn++-- | Wait until data can be written to the given Socket.+-- After this function returns, a call to 'send' will essentially be+-- non-blocking.+waitWrite :: Socket a -> IO () waitWrite = wait' threadWaitWrite pollOut
zeromq3-haskell.cabal view
@@ -1,5 +1,5 @@ name: zeromq3-haskell-version: 0.1.3+version: 0.1.4 synopsis: Bindings to ZeroMQ 3.x category: System, FFI license: MIT