|
|
|
@ -79,7 +79,7 @@ function Connection(config) {
|
|
|
|
|
this._tmrAuth = undefined;
|
|
|
|
|
this._queue = [];
|
|
|
|
|
this._box = undefined;
|
|
|
|
|
this._idle = {};
|
|
|
|
|
this._idle = { started: undefined, enabled: false };
|
|
|
|
|
this._parser = undefined;
|
|
|
|
|
this._curReq = undefined;
|
|
|
|
|
this.delimiter = undefined;
|
|
|
|
@ -90,7 +90,11 @@ function Connection(config) {
|
|
|
|
|
inherits(Connection, EventEmitter);
|
|
|
|
|
|
|
|
|
|
Connection.prototype.connect = function() {
|
|
|
|
|
var config = this._config, self = this, socket, parser, tlsOptions;
|
|
|
|
|
var config = this._config,
|
|
|
|
|
self = this,
|
|
|
|
|
socket,
|
|
|
|
|
parser,
|
|
|
|
|
tlsOptions;
|
|
|
|
|
|
|
|
|
|
socket = config.socket || new Socket();
|
|
|
|
|
socket.setKeepAlive(true);
|
|
|
|
@ -102,7 +106,7 @@ Connection.prototype.connect = function() {
|
|
|
|
|
this._tmrAuth = undefined;
|
|
|
|
|
this._queue = [];
|
|
|
|
|
this._box = undefined;
|
|
|
|
|
this._idle = {};
|
|
|
|
|
this._idle = { started: undefined, enabled: false };
|
|
|
|
|
this._parser = undefined;
|
|
|
|
|
this._curReq = undefined;
|
|
|
|
|
this.delimiter = undefined;
|
|
|
|
|