Merge pull request #47 from j0shua/master

Adding flush parameter when calling client.end

lib/index.js

@@ -59,7 +59,7 @@ internals.Connection.prototype.start = function (callback) {
     client.on('error', (err) => {
 
         if (!self.client) {                             // Failed to connect
-            client.end();
+            client.end(true);
             return callback(err);
         }
     });