1 files changed, 2 insertions, 2 deletions

diff --git a/examples/dhtd.hs b/examples/dhtd.hs
index 0996ffab..4c0cd114 100644
--- a/examples/dhtd.hs
+++ b/examples/dhtd.hs
@@ -1368,10 +1368,10 @@ main = do
 
         forkIO $ do
             myThreadId >>= flip labelThread "XMPP.stanzas"
-            let console = cwPresenceChan $ consoleWriter state
+            let console = cwPresenceChan <$> consoleWriter state
             fix $ \loop -> do
             what <- atomically
-                $ orElse (do (client,stanza) <- takeTMVar console
+                $ orElse (do (client,stanza) <- maybe retry takeTMVar console
                              return $ do informClientPresence0 state Nothing client stanza
                                          loop)
                          (checkQuit >> return (return ()))