git.iko.soy/streamly
on master help sign in
update examples
cef2f7dHarendra Kumar
examples/alternative.hsdeleted−31
compare with master
unifiedsplit
@@ -1,31 +0,0 @@
1−import Control.Concurrent (threadDelay, myThreadId)
2−import Control.Monad.IO.Class (liftIO)
3−import System.Random (randomIO)
4−import System.IO
5−import Control.Applicative
6−
7−import Asyncly
8−
9−main = runAsyncly $ do
10− liftIO $ hSetBuffering stdout LineBuffering
11− mainThread <- liftIO myThreadId
12− liftIO $ putStrLn $ "Main thread: " ++ show mainThread
13−
14− eventA <|> eventB
15−
16−eventA = do
17− liftIO $ threadDelay 1000000
18− x <- liftIO (randomIO :: IO Int)
19− evThread <- liftIO myThreadId
20− liftIO $ putStrLn $ "A Event thread: " ++ show evThread
21− liftIO $ putStrLn $ "a = " ++ (show x)
22− return x
23−
24−eventB = do
25− y <- liftIO (randomIO :: IO Int)
26−
27− -- liftIO $ threadDelay 10000000
28− evThread <- liftIO myThreadId
29− liftIO $ putStrLn $ "B Event thread: " ++ show evThread
30− liftIO $ putStrLn $ "b = " ++ (show y)
31− return y
examples/applicative.hsdeleted−17
@@ -1,17 +0,0 @@
1−{-# LANGUAGE FlexibleContexts #-}
2−
3−import Control.Applicative ((<$>), (<*>), (<|>))
4−import Control.Monad.IO.Class (liftIO)
5−import System.IO
6−import Asyncly
7−
8−main = do
9− hSetBuffering stdout LineBuffering
10− xs <- runAsyncly $ do
11− x <- (,) <$> (event 1 <|> event 2) <*> (event 3 <|> event 4)
12− --x <- (,) <$> (for [1,2] return) <*> (for [3,4] return)
13− liftIO $ putStrLn $ show x
14− return x
15− putStrLn $ show xs
16− where
17− event n = liftIO $ (do putStrLn ("event" ++ show n); return n :: IO Int)
examples/fastest.hs+13−8
@@ -4,12 +4,17 @@
4import Asyncly
4import Asyncly
5import Network.HTTP.Simple
5import Network.HTTP.Simple
6
6
7+-- Runs three search engine queries in parallel.
7main = do
8main = do
8− let urls = [ "https://www.google.com/search?q=haskell"
9+ putStrLn "Using parallel alternative"
9− , "https://www.duckduckgo.com/?q=haskell"
10+ runAsyncly $ google <|> bing <|> duckduckgo
10− , "https://www.bing.com/search?q=haskell"
11+
11− ]
12+ putStrLn "\nUsing parallel applicative zip"
12− xs <- toList $ foldWith (<|>) $ map get urls
13+ runAsyncly $ getZipAsync $
13− mapM_ (putStrLn . show) $ zip [1..] xs
14+ (,,) <$> ZipAsync google <*> ZipAsync bing <*> ZipAsync duckduckgo
14−
15+
16+ where
15− where get s = liftIO $ httpNoBody (parseRequest_ s) >> return s
17+ get s = liftIO (httpNoBody (parseRequest_ s) >> putStrLn (show s))
18+ google = get "https://www.google.com/search?q=haskell"
19+ bing = get "https://www.bing.com/search?q=haskell"
20+ duckduckgo = get "https://www.duckduckgo.com/?q=haskell"
examples/logged.hsdeleted−34
@@ -1,34 +0,0 @@
1−{-# LANGUAGE FlexibleContexts #-}
2−
3−import Control.Applicative ((<$>), (<*>), (<|>))
4−import Control.Monad.IO.Class (liftIO)
5−import System.IO
6−import Asyncly
7−import Control.Monad.Trans.Recorder (pause, record)
8−
9−main = do
10− hSetBuffering stdout LineBuffering
11− logs <- runAsynclyRecorded comp
12−
13− putStrLn $ "\nResuming with logs:"
14− logs1 <- runAsynclyRecorded $ playRecordings comp logs
15−
16− putStrLn $ "\nResuming with logs:"
17− logs2 <- runAsynclyRecorded $ playRecordings comp logs1
18−
19− putStrLn $ "\nLogs at the end must be empty:"
20− putStrLn $ show logs2
21−
22− where
23−
24− comp = record $ threads 5 $ do
25− r <- record $ each [1..3]
26− record $ liftIO $ print ("A",r)
27− record pause
28− record $ liftIO $ print ("B",r)
29− x <- record $ (,) <$> (event 1 <|> event 2) <*> (event 3 <|> event 4)
30− record pause
31− liftIO $ print ("C", r, x)
32−
33− -- event n = async $ liftIO $ (do putStrLn ("event" ++ show n); return n :: IO Int)
34− event n = liftIO $ (do putStrLn ("event" ++ show n); return n :: IO Int)
examples/loop.hs → examples/loops.hsrenamed

The content is the same.