stm-conduit 2.5.3 → 2.5.4
raw patch · 2 files changed
+5/−3 lines, 2 filesPVP: major bump suggested
API removals or changes: PVP suggests a major version bump
API changes (from Hackage documentation)
- Data.Conduit.Async: ($$&) :: (MonadIO m, MonadBaseControl IO m) => Producer m a -> Consumer a m b -> m b
+ Data.Conduit.Async: ($$&) :: (MonadIO m, MonadBaseControl IO m) => Source m a -> Sink a m b -> m b
- Data.Conduit.Async: buffer :: (MonadBaseControl IO m, MonadIO m) => Int -> Producer m a -> Consumer a m b -> m b
+ Data.Conduit.Async: buffer :: (MonadBaseControl IO m, MonadIO m) => Int -> Source m a -> Sink a m r -> m r
Files
- Data/Conduit/Async.hs +4/−2
- stm-conduit.cabal +1/−1
Data/Conduit/Async.hs view
@@ -45,7 +45,7 @@ -- the net effect should be equivalent to not using buffer at all, save for -- the concurrent interleaving of effects. buffer :: (MonadBaseControl IO m, MonadIO m)- => Int -> Producer m a -> Consumer a m b -> m b+ => Int -> Source m a -> Sink a m r -> m r buffer size input output = do chan <- liftIO $ newTBQueueIO size control $ \runInIO ->@@ -70,8 +70,10 @@ -- any use of 'Data.Conduit.$$' with '$$&' and suddenly reap the benefit of -- concurrency, if your conduits were spending time waiting on each other. ($$&) :: (MonadIO m, MonadBaseControl IO m)- => Producer m a -> Consumer a m b -> m b+ => Source m a -> Sink a m b -> m b ($$&) = buffer 64++infixr 0 $$& data BufferContext m a = BufferContext { chan :: TBChan a
stm-conduit.cabal view
@@ -1,5 +1,5 @@ Name: stm-conduit-Version: 2.5.3+Version: 2.5.4 Synopsis: Introduces conduits to channels, and promotes using conduits concurrently. Description: Provides two simple conduit wrappers around STM