Moved dequeue-thread responsibility, implemented receiveCrypto.

1 files changed, 6 insertions, 6 deletions

diff --git a/examples/dhtd.hs b/examples/dhtd.hs
index 8fd1402d..6e2647d1 100644
--- a/examples/dhtd.hs
+++ b/examples/dhtd.hs
@@ -990,12 +990,12 @@ noArgPing f [] x = f x
 noArgPing _ _  _ = return Nothing
 
 newXmmpSource :: Tox.NetCryptoSession -> C.Source IO Tox.CryptoMessage
-newXmmpSource sessions = do
-        v <- liftIO $ _todo sessions {- receive a fucking message -}
-        case v of
-            Nothing            -> return () -- Nothing indicates EOF.
-            Just cryptomessage -> do C.yield cryptomessage
-                                     newXmmpSource sessions
+newXmmpSource session = do
+    v <- liftIO $ Tox.receiveCrypto session
+    case v of
+        Nothing            -> return () -- Nothing indicates EOF.
+        Just cryptomessage -> do C.yield cryptomessage
+                                 newXmmpSource session
 
 newXmmpSink :: Tox.NetCryptoSession -> C.Sink (Flush Tox.CryptoMessage) IO ()
 newXmmpSink sessions = C.awaitForever $ \flush_cyptomessage -> do