aboutsummaryrefslogtreecommitdiff
path: root/hsm-stream/Test/Stream.hs
blob: 327d2e41f1697c982cac32fd7cce87df0947de8c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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