@@ -1454,16 +1454,15 @@ import Control.Monad.Trans.Class (MonadTrans (lift))
14541454-- {-\# LANGUAGE FlexibleContexts #-}
14551455--
14561456-- import "Streamly"
1457−-- import Control.Concurrent (threadDelay)
1457+-- import Streamly.Prelude as S
14581458-- import Control.Monad (when)
14591459-- import Control.Monad.IO.Class (MonadIO(..))
14601460-- import Control.Monad.State (MonadState, get, modify, runStateT)
1461−-- import Data.Semigroup (cycle1)
14621461--
14631462-- data Event = Harm Int | Heal Int | Quit deriving (Show)
14641463--
1465−-- userAction :: MonadIO m => 'SerialT' m Event
1466−-- userAction = cycle1 $ liftIO askUser
1464+-- userAction :: MonadAsync m => 'SerialT' m Event
1465+-- userAction = S.repeatM $ liftIO askUser
14671466-- where
14681467-- askUser = do
14691468-- command <- getLine
@@ -1472,8 +1471,8 @@ import Control.Monad.Trans.Class (MonadTrans (lift))
14721471-- "quit" -> return Quit
14731472-- _ -> putStrLn "What?" >> askUser
14741473--
1475−-- acidRain :: MonadIO m => 'SerialT' m Event
1476−-- acidRain = cycle1 $ liftIO (threadDelay 1000000) >> return (Harm 1)
1474+-- acidRain :: MonadAsync m => SerialT m Event
1475+-- acidRain = asyncly $ constRate 1 $ S.repeatM $ liftIO $ return $ Harm 1
14771476--
14781477-- game :: ('MonadAsync' m, MonadState Int m) => 'SerialT' m ()
14791478-- game = do