Attempt to control buffer sends with renderBytes...

1 files changed, 6 insertions, 3 deletions

diff --git a/Presence/ServerC.hs b/Presence/ServerC.hs
index 36e2d7bf..ae0bf154 100644
--- a/Presence/ServerC.hs
+++ b/Presence/ServerC.hs
@@ -18,6 +18,7 @@ import Data.ByteString.Char8
     )
 import qualified Data.ByteString.Char8 as S
     ( hPutStr
+    , hPutStrLn
     )
 import System.IO 
     ( IOMode(..)
@@ -115,18 +116,20 @@ doServer (HCons family port) g = runServer port (runConn g)
 
 packets :: MonadIO m => Handle -> Source m S.ByteString
 packets h = do
-    packet <- lift $ liftIO $ getPacket h
+    packet <- liftIO $ getPacket h
     yield packet
-    isEof <- lift $ liftIO $ hIsEOF h
+    isEof <- liftIO $ hIsEOF h
     when (not isEof) (packets h)
  where
     getPacket h = do { hWaitForInput h (-1) ; hGetNonBlocking h 1024 }
 
 outgoing :: MonadIO m => Handle -> Sink S.ByteString m ()
 outgoing h = do
+    liftIO . L.putStrLn $ "outgoing: waiting"
     mpacket <- await
+    liftIO . L.putStrLn $ "outgoing: got packet " <++> bshow mpacket
     maybe (return ()) 
-          (\r -> (lift . liftIO . S.hPutStr h $ r) >> outgoing h) 
+          (\r -> (liftIO . S.hPutStrLn h $ r) >> outgoing h) 
           mpacket