diff --git a/lib/stratum.js b/lib/stratum.js
index c0f922e..8048499 100644
--- a/lib/stratum.js
+++ b/lib/stratum.js
@@ -159,6 +159,7 @@ var StratumClient = function(options){
             if (Buffer.byteLength(dataBuffer, 'utf8') > 1024){
                 dataBuffer = '';
                 _this.emit('socketFlooded');
+                socket.end();
                 return;
             }
             if (dataBuffer.slice(-1) === '\n'){