Removed KEEP-ALIVE.

Author: fenying

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes Logs
 
+## v0.1.8
+
+- Removed KEEP-ALIVE.
+
 ## v0.1.7
 
 - Added keep-alive for clients.

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@litert/redis",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "description": "A redis protocol implement for Node.js.",
   "main": "./dist/index.js",
   "scripts": {

package.json

@@ -35,8 +35,6 @@ implements Abstract.RedisClient {
 
     private _listeners!: Dict<Array<Abstract.SubscriptionCallback | Readable>>;
 
-    private _keepAlive: any;
-
     public constructor(
         connection: Net.Socket,
         host: string,
@@ -47,14 +45,6 @@ implements Abstract.RedisClient {
 
         super(connection, host, port, createDecoder, createEncoder);
 
-        this._keepAlive = setInterval(() => {
-
-            if (this._status === Abstract.ClientStatus.NORMAL) {
-
-                this.executeNow("PING").catch((e) => this.emit("error", e));
-            }
-        }, 5000);
-
         this._database = 0;
     }
 
@@ -1323,8 +1313,6 @@ implements Abstract.RedisClient {
             delete this._subscriber;
         }
 
-        clearInterval(this._keepAlive);
-
         return super.close();
     }
 

sources/lib/RedisClient.ts

@@ -34,8 +34,6 @@ implements Abstract.ProtocolClient {
 
     protected _password: string;
 
-    private _keepAlive: any;
-
     public constructor(
         connection: Net.Socket,
         host: string,
@@ -46,14 +44,6 @@ implements Abstract.ProtocolClient {
     ) {
         super(connection, host, port, createDecoder, createEncoder);
 
-        this._keepAlive = setInterval(() => {
-
-            if (this._status === Abstract.ClientStatus.NORMAL) {
-
-                this.executeNow("PING").catch((e) => this.emit("error", e));
-            }
-        }, 5000);
-
         this._subjects = [];
         this._patterns = [];
         this._password = password;
@@ -329,8 +319,6 @@ implements Abstract.ProtocolClient {
 
     public async close(): Promise<void> {
 
-        clearInterval(this._keepAlive);
-
         return super.close();
     }
 }