c6bc139 · streamly · git.iko.soy

git.iko.soy/streamly

Make sequence concurrent

commitc6bc13963f9de6b0dfa6a1e80a77413765ecdac7 authorRanjeet Kumar Ranjan <ranjeetr@composewell.com> dateWed 15 Sep 2021, 14:56 (5 years ago) parent8f03957

2 files changed+5−1

compare with master

unifiedsplit

src/Streamly/Internal/Data/Stream/IsStream/Transform.hs+1−1 test/Streamly/Test/Prelude/Concurrent.hs+4

src/Streamly/Internal/Data/Stream/IsStream/Transform.hs+1−1

@@ -437,7 +437,7 @@ mapMSerial = Serial.mapM

437437-- @since 0.1.0

438438{-# INLINE sequence #-}

439439sequence :: (IsStream t, MonadAsync m) => t m (m a) -> t m a

440−sequence m = fromStreamS $ S.sequence (toStreamS m)

440+sequence = mapM id

441441

442442------------------------------------------------------------------------------

443443-- Mapping side effects

test/Streamly/Test/Prelude/Concurrent.hs+4

@@ -164,6 +164,10 @@ concurrentOps constr desc eq t = do

164164 concurrentMapM constr eq $ \n mv stream ->

165165 t $ S.mapM (mvarSequenceOp mv n) stream

166166

167+ prop1 (desc <> " sequence") $

168+ concurrentMapM constr eq $ \n mv stream ->

169+ t $ S.sequence $ S.map (mvarSequenceOp mv n) stream

170+

167171-------------------------------------------------------------------------------

168172-- Concurrent Application

169173-------------------------------------------------------------------------------