import Control.Concurrent (threadDelay) import Data.Function ((&)) import Effectful (liftIO, runEff) import Hsm.Log (Severity (Info), runLog) import Hsm.Stream (runStream, startStream) main :: IO () main = (startStream >> liftIO (threadDelay $ maxBound @Int)) & runStream True & runLog @"stream" Info & runEff