stomp-conduit 0.1.0 → 0.5.0
raw patch · 3 files changed
+23/−18 lines, 3 filesdep ~conduitdep ~mimedep ~mtlPVP ok
version bump matches the API change (PVP)
Dependency ranges changed: conduit, mime, mtl, resourcet, stomp-queue, stompl
API changes (from Hackage documentation)
- Network.Mom.Stompl.Client.Conduit: qMultiSink :: MonadResource m => Writer o -> Type -> [Header] -> Consumer o m ()
+ Network.Mom.Stompl.Client.Conduit: qMultiSink :: MonadIO m => Writer o -> Type -> [Header] -> ConduitT o Void m ()
- Network.Mom.Stompl.Client.Conduit: qMultiSource :: MonadResource m => Reader i -> Int -> Producer m (Message i)
+ Network.Mom.Stompl.Client.Conduit: qMultiSource :: MonadIO m => Reader i -> Int -> ConduitT () (Message i) m ()
- Network.Mom.Stompl.Client.Conduit: qSink :: MonadResource m => Writer o -> Type -> [Header] -> Consumer o m ()
+ Network.Mom.Stompl.Client.Conduit: qSink :: MonadIO m => Writer o -> Type -> [Header] -> ConduitT o Void m ()
- Network.Mom.Stompl.Client.Conduit: qSource :: MonadResource m => Reader i -> Int -> Producer m (Message i)
+ Network.Mom.Stompl.Client.Conduit: qSource :: MonadIO m => Reader i -> Int -> ConduitT () (Message i) m ()
Files
- Network/Mom/Stompl/Client/Conduit.hs +9/−9
- changelog.md +3/−0
- stomp-conduit.cabal +11/−9
Network/Mom/Stompl/Client/Conduit.hs view
@@ -25,7 +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 Control.Monad.IO.Class (MonadIO) import System.Timeout import Network.Mom.Stompl.Client.Queue@@ -44,8 +44,8 @@ -- -- * Int: Timeout in microseconds ------------------------------------------------------------------------- qSource :: MonadResource m => - Reader i -> Int -> C.Producer m (Message i)+ qSource :: MonadIO m => + Reader i -> Int -> C.ConduitT () (Message i) m () qSource r tmo = go where go = liftIO (timeout tmo $ readQ r) >>= mbYield mbYield mbX = case mbX of@@ -65,8 +65,8 @@ -- -- * ['Header']: Headers to add to each message. ------------------------------------------------------------------------- qSink :: MonadResource m => - Writer o -> Type -> [Header] -> C.Consumer o m ()+ qSink :: MonadIO m => + Writer o -> Type -> [Header] -> C.ConduitT o C.Void m () qSink w t hs = C.awaitForever $ \x -> liftIO (writeQ w t hs x) -- header to mark the last segment of a multipart message -------------@@ -84,8 +84,8 @@ -- -- For parameters, please refer to 'qSource'. ------------------------------------------------------------------------- qMultiSource :: MonadResource m =>- Reader i -> Int -> C.Producer m (Message i)+ qMultiSource :: MonadIO m =>+ Reader i -> Int -> C.ConduitT () (Message i) m () qMultiSource r tmo = loop where loop = do mbX <- liftIO (timeout tmo $ readQ r)@@ -105,8 +105,8 @@ -- -- For parameters, please refer to 'qSink'. ------------------------------------------------------------------------- qMultiSink :: MonadResource m =>- Writer o -> Type -> [Header] -> C.Consumer o m ()+ qMultiSink :: MonadIO m =>+ Writer o -> Type -> [Header] -> C.ConduitT o C.Void m () qMultiSink w t hs = do mbX <- C.await case mbX of
changelog.md view
@@ -1,3 +1,6 @@+__0.5.0__+ New versions of conduit, stompl and stomp-queue+ __0.1.0__ Static Linking Exception in License
stomp-conduit.cabal view
@@ -1,7 +1,7 @@ Name: stomp-conduit-Version: 0.1.0-Cabal-Version: >= 1.8-Copyright: Copyright (c) Tobias Schoofs, 2013 - 2015+Version: 0.5.0+Cabal-Version: >= 1.24+Copyright: Copyright (c) Tobias Schoofs, 2013 - 2020 License: LGPL license-file: license/lgpl-3.0ex.txt Author: Tobias Schoofs@@ -41,12 +41,14 @@ Library Build-Depends: base >= 4.0 && <= 5.0,- 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+ stomp-queue >= 0.5.1,+ stompl >= 0.6.0,+ conduit >= 1.3.4,+ mtl >= 2.2.0,+ resourcet >= 1.2.4,+ mime >= 0.4.0++ default-language: Haskell98 hs-source-dirs: Network/Mom/Stompl/Client, .