Fixed the method close for TCP connection provider.

litert · May 28, 2018 · 5b4e3cb · 5b4e3cb
1 parent 7de35e6
commit 5b4e3cb
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -3,3 +3,4 @@
 ## v0.1.1
 
 - Added option `connectTimeout` for TCP connection provider.
+- Fixed the method `close` for TCP connection provider.
diff --git a/src/samples/redis.ts b/src/samples/redis.ts
@@ -32,6 +32,10 @@ connector.on("connected", function() {
     c.on("data", function(data) {
 
         console.log(data.toString());
+
+    }).on("end", function() {
+
+        console.log("Ended.");
     });
 
     c.write("AUTH redis-passwd\r\n");
@@ -46,6 +50,8 @@ connector.on("connected", function() {
 
     c.write("MGET d b\r\n");
 
+    setTimeout(() => connector.close(), 5000);
+
 }).on("error", function(e) {
 
     console.error(e);

diff --git a/src/tcp.ts b/src/tcp.ts
@@ -83,10 +83,9 @@ implements ConnectionProvider<$Net.Socket, NodeJS.ErrnoException> {
 
     public close(): void {
 
-        if (this._conn && !this._conn.destroyed) {
+        if (this._conn && this._conn.writable) {
 
-            this._conn.destroy();
-            delete this._conn;
+            this._conn.end();
         }
     }