/home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/connectors
NameSizeModeActions
SentinelConnector/-0777rm
AbstractConnector.d.ts4420666editdlrm
AbstractConnector.js9060666editdlrm
ConnectorConstructor.d.ts1720666editdlrm
ConnectorConstructor.js770666editdlrm
index.d.ts1610666editdlrm
index.js3850666editdlrm
StandaloneConnector.d.ts7930666editdlrm
StandaloneConnector.js24490666editdlrm
Edit: /home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/connectors/AbstractConnector.js (906B)
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); const utils_1 = require("../utils"); const debug = (0, utils_1.Debug)("AbstractConnector"); class AbstractConnector { constructor(disconnectTimeout) { this.connecting = false; this.disconnectTimeout = disconnectTimeout; } check(info) { return true; } disconnect() { this.connecting = false; if (this.stream) { const stream = this.stream; // Make sure callbacks refer to the same instance const timeout = setTimeout(() => { debug("stream %s:%s still open, destroying it", stream.remoteAddress, stream.remotePort); stream.destroy(); }, this.disconnectTimeout); stream.on("close", () => clearTimeout(timeout)); stream.end(); } } } exports.default = AbstractConnector;