@@ -1,7 +1,7 @@
11import Control.Monad.IO.Class (liftIO)
22import Path.IO (listDir, getCurrentDir)
33import System.IO (stdout, hSetBuffering, BufferMode(LineBuffering))
4−import Streamly (runStream, asyncly)
4+import Streamly (runStream, aheadly)
55
66-- | List the current directory recursively using concurrent processing
77--
@@ -11,7 +11,7 @@ import Streamly (runStream, asyncly)
1111main :: IO ()
1212main = do
1313 hSetBuffering stdout LineBuffering
14− runStream . asyncly $ getCurrentDir >>= readdir
14+ runStream . aheadly $ getCurrentDir >>= readdir
1515 where readdir d = do
1616 (ds, fs) <- liftIO $ listDir d
1717 liftIO $ mapM_ putStrLn $ map show fs ++ map show ds