Switch to LockedChan, easier to debug.

1 files changed, 6 insertions, 1 deletions

diff --git a/Presence/LockedChan.hs b/Presence/LockedChan.hs
index e7e951bb..a562bc58 100644
--- a/Presence/LockedChan.hs
+++ b/Presence/LockedChan.hs
@@ -27,8 +27,13 @@ unlockChan c = do
 writeLChan :: LockedChan a -> a -> STM ()
 writeLChan c a = writeTChan (chan c) a
 
+-- This one blocks rather than throwing an exception...
+-- todo: probably this should be changed to conform to the rest
+-- of the api.
 peekLChan :: LockedChan a -> STM a
-peekLChan c = peekTChan (chan c)
+peekLChan c = do
+    readTVar (lock c) >>= check
+    peekTChan (chan c)
 
 newLockedChan :: STM (LockedChan a)
 newLockedChan = do