streaming-concurrency 0.3.1.2 → 0.3.1.3
raw patch · 3 files changed
+14/−7 lines, 3 filesdep ~hspecdep ~lifted-asyncdep ~stmPVP: major bump suggested
API removals or changes: PVP suggests a major version bump
Dependency ranges changed: hspec, lifted-async, stm
API changes (from Hackage documentation)
- Streaming.Concurrent: joinBuffers :: (MonadBase IO m) => (a -> b) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent: joinBuffers :: MonadBase IO m => (a -> b) -> OutBasket a -> InBasket b -> m ()
- Streaming.Concurrent: joinBuffersM :: (MonadBase IO m) => (a -> m b) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent: joinBuffersM :: MonadBase IO m => (a -> m b) -> OutBasket a -> InBasket b -> m ()
- Streaming.Concurrent: joinBuffersStream :: (MonadBase IO m) => (Stream (Of a) m () -> Stream (Of b) m t) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent: joinBuffersStream :: MonadBase IO m => (Stream (Of a) m () -> Stream (Of b) m t) -> OutBasket a -> InBasket b -> m ()
- Streaming.Concurrent: withStreamBasket :: (MonadBase IO m) => OutBasket a -> (Stream (Of a) m () -> r) -> r
+ Streaming.Concurrent: withStreamBasket :: MonadBase IO m => OutBasket a -> (Stream (Of a) m () -> r) -> r
- Streaming.Concurrent: writeStreamBasket :: (MonadBase IO m) => Stream (Of a) m r -> InBasket a -> m ()
+ Streaming.Concurrent: writeStreamBasket :: MonadBase IO m => Stream (Of a) m r -> InBasket a -> m ()
- Streaming.Concurrent.Lifted: joinBuffers :: (MonadBase IO m) => (a -> b) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent.Lifted: joinBuffers :: MonadBase IO m => (a -> b) -> OutBasket a -> InBasket b -> m ()
- Streaming.Concurrent.Lifted: joinBuffersM :: (MonadBase IO m) => (a -> m b) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent.Lifted: joinBuffersM :: MonadBase IO m => (a -> m b) -> OutBasket a -> InBasket b -> m ()
- Streaming.Concurrent.Lifted: joinBuffersStream :: (MonadBase IO m) => (Stream (Of a) m () -> Stream (Of b) m t) -> OutBasket a -> InBasket b -> m ()
+ Streaming.Concurrent.Lifted: joinBuffersStream :: MonadBase IO m => (Stream (Of a) m () -> Stream (Of b) m t) -> OutBasket a -> InBasket b -> m ()
Files
- ChangeLog.md +7/−0
- src/Streaming/Concurrent.hs +2/−2
- streaming-concurrency.cabal +5/−5
ChangeLog.md view
@@ -1,5 +1,12 @@ # Revision history for streaming-concurrency +## 0.3.1.3 -- 2019-05-13++* Bump/fix dependencies for:+ - stm+ - hspec+ - lifted-async+ ## 0.3.1.2 -- 2018-05-23 * Bump lifted-async dependency.
src/Streaming/Concurrent.hs view
@@ -331,7 +331,7 @@ openBasket = do (writeB, readB) <- case buffer of Bounded n -> do- q <- STM.newTBQueueIO n+ q <- STM.newTBQueueIO (fromIntegral n) return (STM.writeTBQueue q, STM.readTBQueue q) Unbounded -> do q <- STM.newTQueueIO@@ -346,7 +346,7 @@ m <- STM.newEmptyTMVarIO return (\x -> STM.tryTakeTMVar m *> STM.putTMVar m x, STM.takeTMVar m) Newest n -> do- q <- STM.newTBQueueIO n+ q <- STM.newTBQueueIO (fromIntegral n) let writeB x = STM.writeTBQueue q x <|> (STM.tryReadTBQueue q *> writeB x) return (writeB, STM.readTBQueue q)
streaming-concurrency.cabal view
@@ -1,5 +1,5 @@ name: streaming-concurrency-version: 0.3.1.2+version: 0.3.1.3 synopsis: Concurrency support for the streaming ecosystem description: There are two primary higher-level use-cases for this library:@@ -23,7 +23,7 @@ extra-source-files: ChangeLog.md, README.md cabal-version: >=1.10 tested-with: GHC == 7.10.2, GHC == 8.0.2, GHC == 8.2.2,- GHC == 8.4.1, GHC == 8.5.*+ GHC == 8.4.1, GHC == 8.6.5, GHC == 8.8.1 source-repository head type: git@@ -34,9 +34,9 @@ , Streaming.Concurrent.Lifted build-depends: base ==4.* , exceptions >= 0.6 && < 0.11- , lifted-async >= 0.9.3 && < 0.111+ , lifted-async >= 0.9.3 && < 0.11 , monad-control == 1.*- , stm >= 2.4 && < 3+ , stm >= 2.4 && < 2.6 , streaming >= 0.1.4.0 && < 0.3 , streaming-with >= 0.1.0.0 && < 0.3 , transformers-base@@ -48,7 +48,7 @@ main-is: merging.hs build-depends: streaming-concurrency , base- , hspec == 2.4.*+ , hspec >= 2.4 && < 2.8 , QuickCheck == 2.* , quickcheck-instances , streaming