aboutsummaryrefslogtreecommitdiff
path: root/hsm-dummy-poller
diff options
context:
space:
mode:
Diffstat (limited to 'hsm-dummy-poller')
-rw-r--r--hsm-dummy-poller/Main.hs5
1 files changed, 1 insertions, 4 deletions
diff --git a/hsm-dummy-poller/Main.hs b/hsm-dummy-poller/Main.hs
index 762d139..9f2fad9 100644
--- a/hsm-dummy-poller/Main.hs
+++ b/hsm-dummy-poller/Main.hs
@@ -27,16 +27,13 @@ data Env = Env
$(deriveFromYaml ''Env)
handle ::
- forall es. (Concurrent :> es, Log :> es, Reader Env :> es)
+ (Concurrent :> es, Log :> es, Reader Env :> es)
=> S.Stream (Eff es) [Int]
-> Eff es ()
handle =
S.fold S.drain . S.mapM (\p -> asks period >>= threadDelay >> handler p)
where
- receiverDomain :: Text
receiverDomain = "receiver"
- --
- handler :: [Int] -> Eff es ()
handler [] = localDomain receiverDomain $ logInfo_ "No pulse received yet"
handler ps =
forM_ ps $ \p ->