stm-conduit 2.5.2 → 2.5.3

raw patch · 2 files changed

+10/−9 lines, 2 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• Data/Conduit/Async.hs +9/−8
• stm-conduit.cabal +1/−1

@@ -16,6 +16,7 @@                           ) where  import           Control.Applicative+import qualified Control.Concurrent.Async as A import           Control.Concurrent.Async.Lifted import           Control.Concurrent.STM import           Control.Concurrent.STM.TBChan@@ -48,10 +49,10 @@ buffer size input output = do     chan <- liftIO $ newTBQueueIO size     control $ \runInIO ->-        withAsync (runInIO $ sender chan) $ \input' ->-        withAsync (runInIO $ recv chan $$ output) $ \output' -> do-            link2 input' output'-            wait output'+        A.withAsync (runInIO $ sender chan) $ \input' ->+        A.withAsync (runInIO $ recv chan $$ output) $ \output' -> do+            A.link2 input' output'+            A.wait output'   where     send chan = liftIO . atomically . writeTBQueue chan @@ -100,10 +101,10 @@         <*> newTVarIO fileMax         <*> newTVarIO False     control $ \runInIO ->-        withAsync (runInIO $ sender context) $ \input' ->-        withAsync (runInIO $ recv context $$ output) $ \output' -> do-            link2 input' output'-            wait output'+        A.withAsync (runInIO $ sender context) $ \input' ->+        A.withAsync (runInIO $ recv context $$ output) $ \output' -> do+            A.link2 input' output'+            A.wait output'   where     sender BufferContext {..} = do         input $$ awaitForever $ \x -> join $ liftIO $ atomically $ do

@@ -1,5 +1,5 @@ Name:                stm-conduit-Version:             2.5.2+Version:             2.5.3 Synopsis:            Introduces conduits to channels, and promotes using                      conduits concurrently. Description:         Provides two simple conduit wrappers around STM