Implements keep alive options.

sidorares · Dec 13, 2019 · 288d997 · 288d997
1 parent 607aa29
commit 288d997
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/connection.js b/lib/connection.js
@@ -44,8 +44,10 @@ class Connection extends EventEmitter {
       this.stream = opts.config.stream;
     }
 
-    // Enable keep-alive on the socket.
-    this.stream.setKeepAlive(true, 10000);
+    // Enable keep-alive on the socket.  It's disabled by default, but the
+    // user can enable it and supply an initial delay.
+    if (typeof this.stream.setKeepAlive === 'function' && this.config.enableKeepAlive)
+      this.stream.setKeepAlive(true, this.config.keepAliveInitialDelay);
 
     this._internalId = _connectionId++;
     this._commands = new Queue();