conduit-concurrent-map 0.1.0 → 0.1.1

raw patch · 2 files changed

+2/−2 lines, 2 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• conduit-concurrent-map.cabal +1/−1
• src/Data/Conduit/ConcurrentMap.hs +1/−1

@@ -1,5 +1,5 @@ name:          conduit-concurrent-map-version:       0.1.0+version:       0.1.1 license:       MIT copyright:     2017 Niklas Hambüchen <mail@nh2.me> author:        Niklas Hambüchen <mail@nh2.me>

@@ -109,7 +109,7 @@ -- -- > puts :: (MonadIO m) => String -> m () -- for non-interleaved output -- > puts s = liftIO $ BS8.putStrLn (BS8.pack s)--- > runConduitRes (CL.sourceList [1..6] .| conduitconcurrentMapM_ 4 (\i -> liftIO $ puts (show i ++ " before") >> threadDelay (i * 1000000) >> puts (show i ++ " after") >> return (i*2)) .| CL.consume )+-- > runConduitRes (CL.sourceList [1..6] .| concurrentMapM_ 4 (\i -> liftIO $ puts (show i ++ " before") >> threadDelay (i * 1000000) >> puts (show i ++ " after") >> return (i*2)) .| CL.consume ) concurrentMapM_ :: (MonadUnliftIO m, MonadResource m) => Int -> Int -> (a -> m b) -> ConduitT a b m () concurrentMapM_ numThreads workerOutputBufferSize f = do   when (workerOutputBufferSize < 1) $ do