diff --git a/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy b/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy
index 63cc7fea..109c5f1e 100644
--- a/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy
+++ b/core/src/main/groovy/com/muwire/core/connection/ConnectionAcceptor.groovy
@@ -468,6 +468,7 @@ class ConnectionAcceptor {
             else if (version == 2)
                 browseManager.processV2Request(browser, e)
         } finally {
+            try {e.getOutputStream().close()} catch (IOException ignore) {}
             e.close()
         }
     }
diff --git a/core/src/main/groovy/com/muwire/core/search/BrowseSession.groovy b/core/src/main/groovy/com/muwire/core/search/BrowseSession.groovy
index 2a104fdb..27bd7ef0 100644
--- a/core/src/main/groovy/com/muwire/core/search/BrowseSession.groovy
+++ b/core/src/main/groovy/com/muwire/core/search/BrowseSession.groovy
@@ -214,6 +214,7 @@ class BrowseSession implements Runnable {
             }
         } finally {
             currentThread = null
+            endpoint?.getOutputStream()?.close()
             endpoint?.close()
         }
     }