@@ -1,7 +1,7 @@
1import Control.Monad.IO.Class (liftIO)
1import Control.Monad.IO.Class (liftIO)
2import Path.IO (listDir, getCurrentDir)
2import Path.IO (listDir, getCurrentDir)
3import System.IO (stdout, hSetBuffering, BufferMode(LineBuffering))
3import System.IO (stdout, hSetBuffering, BufferMode(LineBuffering))
4−import Streamly (runStream, asyncly)
4+import Streamly (runStream, aheadly)
6-- | List the current directory recursively using concurrent processing
6-- | List the current directory recursively using concurrent processing
@@ -11,7 +11,7 @@ import Streamly (runStream, asyncly)
11main :: IO ()
11main :: IO ()
13 hSetBuffering stdout LineBuffering
13 hSetBuffering stdout LineBuffering
14− runStream . asyncly $ getCurrentDir >>= readdir
14+ runStream . aheadly $ getCurrentDir >>= readdir
15 where readdir d = do
15 where readdir d = do
16 (ds, fs) <- liftIO $ listDir d
16 (ds, fs) <- liftIO $ listDir d
17 liftIO $ mapM_ putStrLn $ map show fs ++ map show ds
17 liftIO $ mapM_ putStrLn $ map show fs ++ map show ds