import Data.Function ((&))
import Effectful (runEff)
import Effectful.Concurrent (runConcurrent, threadDelay)
import Effectful.Fail (runFailIO)
import Hsm.Log (Severity (Trace), runLogs)
import Hsm.Stream (runStream, startStream)

main :: IO ()
main =
  (startStream >> threadDelay (maxBound @Int))
    & runStream
    & runLogs @'["gst", "stream"] Trace
    & runConcurrent
    & runFailIO
    & runEff