772dbd4 · streamly · git.iko.soy

src/Streamly/Streams/Ahead.hs+1−1

compare with master

unifiedsplit

@@ -580,7 +580,7 @@ consMAhead m r = K.yieldM m `aheadS` r

580--

581-- main = 'runStream' . 'aheadly' $ do

582-- n <- return 3 \<\> return 2 \<\> return 1

583−-- S.once $ do

583+-- S.yieldM $ do

584-- threadDelay (n * 1000000)

585-- myThreadId >>= \\tid -> putStrLn (show tid ++ ": Delay " ++ show n)

586-- @

src/Streamly/Streams/Async.hs+2−2

@@ -636,7 +636,7 @@ consMAsync m r = K.yieldM m `asyncS` r

636--

637-- main = 'runStream' . 'asyncly' $ do

638-- n <- return 3 \<\> return 2 \<\> return 1

639−-- S.once $ do

639+-- S.yieldM $ do

640-- threadDelay (n * 1000000)

641-- myThreadId >>= \\tid -> putStrLn (show tid ++ ": Delay " ++ show n)

642-- @

@@ -762,7 +762,7 @@ wAsync m1 m2 = fromStream $ Stream $ \st stp sng yld ->

762--

763-- main = 'runStream' . 'wAsyncly' $ do

764-- n <- return 3 \<\> return 2 \<\> return 1

765−-- S.once $ do

765+-- S.yieldM $ do

766-- threadDelay (n * 1000000)

767-- myThreadId >>= \\tid -> putStrLn (show tid ++ ": Delay " ++ show n)

768-- @

src/Streamly/Streams/Parallel.hs+1−1

@@ -307,7 +307,7 @@ x |&. f = f |$. x

307--

308-- main = 'runStream' . 'parallely' $ do

309-- n <- return 3 \<\> return 2 \<\> return 1

310−-- S.once $ do

310+-- S.yieldM $ do

311-- threadDelay (n * 1000000)

312-- myThreadId >>= \\tid -> putStrLn (show tid ++ ": Delay " ++ show n)

313-- @

src/Streamly/Streams/Serial.hs+3−3

@@ -86,7 +86,7 @@ import qualified Streamly.Streams.StreamD as D

86-- @

87-- main = 'runStream' . 'serially' $ do

88-- x <- return 1 \<\> return 2

89−-- S.once $ print x

89+-- S.yieldM $ print x

90-- @

91-- @

92-- 1

@@ -99,7 +99,7 @@ import qualified Streamly.Streams.StreamD as D

99-- main = 'runStream' . 'serially' $ do

100-- x <- return 1 \<\> return 2

101-- y <- return 3 \<\> return 4

102−-- S.once $ print (x, y)

102+-- S.yieldM $ print (x, y)

103-- @

104-- @

105-- (1,3)

@@ -227,7 +227,7 @@ MONAD_COMMON_INSTANCES(SerialT,)

227-- main = 'runStream' . 'wSerially' $ do

228-- x <- return 1 \<\> return 2

229-- y <- return 3 \<\> return 4

230−-- S.once $ print (x, y)

230+-- S.yieldM $ print (x, y)

231-- @

232-- @

233-- (1,3)