1 files changed, 3 insertions, 2 deletions

diff --git a/server/src/Network/QueryResponse/TCP.hs b/server/src/Network/QueryResponse/TCP.hs
index 8b1b432b..24aacd98 100644
--- a/server/src/Network/QueryResponse/TCP.hs
+++ b/server/src/Network/QueryResponse/TCP.hs
@@ -213,8 +213,9 @@ tcpTransport maxcon stream = do
     msgvar <- atomically newEmptyTMVar
     tcpcache <- atomically $ (`TCPCache` maxcon) <$> newTVar (MM.empty)
     return $ (,) tcpcache Transport
-        { awaitMessage   = \f -> takeTMVar msgvar >>= \x -> return $ do
-            f x `catchIOError` (\e -> dput XTCP ("TCP transport stopped. " ++ show e) >> f Terminated)
+        { awaitMessage   = do
+            x <- takeTMVar msgvar
+            return (x, return ())
         , sendMessage    = \addr (bDoCon,y) -> do
                                 void . forkLabeled "tcp-send" $ do
                                     msock <- acquireConnection msgvar tcpcache stream addr bDoCon