diff options
-rw-r--r-- | Announcer.hs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/Announcer.hs b/Announcer.hs index e4b19bd7..6d971ebf 100644 --- a/Announcer.hs +++ b/Announcer.hs | |||
@@ -179,7 +179,7 @@ listener announcer = relisten | |||
179 | UnscheduleAction k -> atomically $ modifyScheduled $ PSQ.delete k | 179 | UnscheduleAction k -> atomically $ modifyScheduled $ PSQ.delete k |
180 | RunActionSTM k (ScheduledItem f) -> do | 180 | RunActionSTM k (ScheduledItem f) -> do |
181 | now <- getPOSIXTime | 181 | now <- getPOSIXTime |
182 | join (atomically $ f announcer k now) | 182 | join . atomically $ modifyScheduled (PSQ.delete k) >> f announcer k now |
183 | DelayAction (k, p, s) -> do | 183 | DelayAction (k, p, s) -> do |
184 | now <- getPOSIXTime | 184 | now <- getPOSIXTime |
185 | atomically $ modifyScheduled $ PSQ.insert' k s (now + p) | 185 | atomically $ modifyScheduled $ PSQ.insert' k s (now + p) |