stomp-conduit 0.0.1 → 0.0.2
raw patch · 2 files changed
+14/−9 lines, 2 filesdep +resourcetdep ~stomp-queuedep ~stompl
Dependencies added: resourcet
Dependency ranges changed: stomp-queue, stompl
Files
Network/Mom/Stompl/Client/Conduit.hs view
@@ -1,3 +1,4 @@+{-# Language RankNTypes #-} ------------------------------------------------------------------------------- -- | -- Module : Network/Mom/Stompl/Client/Conduit.hs@@ -24,6 +25,7 @@ import qualified Data.Conduit as C import Codec.MIME.Type (Type) import Control.Monad.Trans (liftIO)+ import Control.Monad.Trans.Resource (MonadResource) import System.Timeout import Network.Mom.Stompl.Client.Queue@@ -42,7 +44,7 @@ -- -- * Int: Timeout in microseconds ------------------------------------------------------------------------- qSource :: C.MonadResource m => + qSource :: MonadResource m => Reader i -> Int -> C.Producer m (Message i) qSource r tmo = go where go = liftIO (timeout tmo $ readQ r) >>= mbYield@@ -63,7 +65,7 @@ -- -- * ['Header']: Headers to add to each message. ------------------------------------------------------------------------- qSink :: C.MonadResource m => + qSink :: MonadResource m => Writer o -> Type -> [Header] -> C.Consumer o m () qSink w t hs = C.awaitForever $ \x -> liftIO (writeQ w t hs x) @@ -82,7 +84,7 @@ -- -- For parameters, please refer to 'qSource'. ------------------------------------------------------------------------- qMultiSource :: C.MonadResource m =>+ qMultiSource :: MonadResource m => Reader i -> Int -> C.Producer m (Message i) qMultiSource r tmo = loop where loop = do@@ -103,7 +105,7 @@ -- -- For parameters, please refer to 'qSink'. ------------------------------------------------------------------------- qMultiSink :: C.MonadResource m =>+ qMultiSink :: MonadResource m => Writer o -> Type -> [Header] -> C.Consumer o m () qMultiSink w t hs = do mbX <- C.await
stomp-conduit.cabal view
@@ -1,7 +1,7 @@ Name: stomp-conduit-Version: 0.0.1+Version: 0.0.2 Cabal-Version: >= 1.8-Copyright: Copyright (c) Tobias Schoofs, 2013+Copyright: Copyright (c) Tobias Schoofs, 2013 - 2014 License: LGPL license-file: license/lgpl-3.0.txt Author: Tobias Schoofs@@ -29,7 +29,7 @@ either infinite streams or multipart messages with an explicit last message segment. The latter concept is- and extension of the Stomp specification.+ an extension of the Stomp specification. . @@ -46,16 +46,19 @@ [0.0.1] Initial release + extra-source-files: changelog.txt Library Build-Depends: base >= 4.0 && <= 5.0,- stomp-queue >= 0.0.7,- stompl >= 0.0.3,+ stomp-queue >= 0.1.1,+ stompl >= 0.1.1, conduit >= 1.0.8, mtl >= 2.1.2,+ resourcet >= 1.1.2.2, mime >= 0.3.3 hs-source-dirs: Network/Mom/Stompl/Client, . Exposed-Modules: Network.Mom.Stompl.Client.Conduit+