772dbd4 · streamly · git.iko.soy

git.iko.soy/streamly

replace "once" with "yieldM" in examples

commit772dbd40929bbd917fc5665d406a3ceb8aba4633 authorHarendra Kumar <harendra.kumar@gmail.com> dateTue 4 Sep 2018, 18:05 (8 years ago) parenteeb3b03

4 files changed+7−7

compare with master

unifiedsplit

src/Streamly/Streams/Ahead.hs+1−1 src/Streamly/Streams/Async.hs+2−2 src/Streamly/Streams/Parallel.hs+1−1 src/Streamly/Streams/Serial.hs+3−3

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

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

580580--

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

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

583−-- S.once $ do

583+-- S.yieldM $ do

584584-- threadDelay (n * 1000000)

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

586586-- @

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

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

636636--

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

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

639−-- S.once $ do

639+-- S.yieldM $ do

640640-- threadDelay (n * 1000000)

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

642642-- @

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

762762--

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

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

765−-- S.once $ do

765+-- S.yieldM $ do

766766-- threadDelay (n * 1000000)

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

768768-- @

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

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

307307--

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

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

310−-- S.once $ do

310+-- S.yieldM $ do

311311-- threadDelay (n * 1000000)

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

313313-- @

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

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

8686-- @

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

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

89−-- S.once $ print x

89+-- S.yieldM $ print x

9090-- @

9191-- @

9292-- 1

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

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

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

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

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

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

103103-- @

104104-- @

105105-- (1,3)

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

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

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

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

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

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

231231-- @

232232-- @

233233-- (1,3)