import qualified Streamly.Prelude as S import qualified Streamly.Internal.Data.Stream.IsStream as Internal main :: IO () main = S.mapM_ print $ S.asyncly $ S.avgRate 1 $ Internal.timestamped $ S.repeatM (pure "tick")