diff --git a/core/src/main/groovy/com/muwire/core/connection/Endpoint.groovy b/core/src/main/groovy/com/muwire/core/connection/Endpoint.groovy
index 3bc140d6..5e13ff5c 100644
--- a/core/src/main/groovy/com/muwire/core/connection/Endpoint.groovy
+++ b/core/src/main/groovy/com/muwire/core/connection/Endpoint.groovy
@@ -34,7 +34,7 @@ class Endpoint implements Closeable {
 			try {outputStream.close()} catch (Exception ignore) {}
 		}
         if (toClose != null) {
-            try {toClose.close()} catch (Exception ignore) {}
+            try {toClose.reset()} catch (Exception ignore) {}
         }
 	}