@@ -69,9 +69,8 @@ processAsyncEvents events run (FireCommand fire) = forkIO $ forever $ do
69 ers <- readChan events
69 ers <- readChan events
70 _ <- run $ do
70 _ <- run $ do
72− liftIO $ for ers $ \(EventTriggerRef er :=> TriggerInvocation a _) -> do
72+ liftIO $ for ers $ \(EventTriggerRef er :=> TriggerInvocation a _) ->
74− return $ fmap (\e -> e :=> Identity a) me
73+ fmap (\ e -> e :=> Identity a) <$> readIORef er
75 _ <- fire (catMaybes mes) $ return ()
74 _ <- fire (catMaybes mes) $ return ()
76 liftIO $ for_ ers $ \(_ :=> TriggerInvocation _ cb) -> cb
75 liftIO $ for_ ers $ \(_ :=> TriggerInvocation _ cb) -> cb