FM / built

/home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/

/home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built

Name	Size	Mode	Actions
cluster/	-	0777	rm
connectors/	-	0777	rm
constants/	-	0777	rm
errors/	-	0777	rm
redis/	-	0777	rm
utils/	-	0777	rm
autoPipelining.d.ts	625	0666	edit dl rm
autoPipelining.js	7118	0666	edit dl rm
Command.d.ts	5349	0666	edit dl rm
Command.js	15004	0666	edit dl rm
DataHandler.d.ts	1170	0666	edit dl rm
DataHandler.js	8468	0666	edit dl rm
index.d.ts	1472	0666	edit dl rm
index.js	2570	0666	edit dl rm
Pipeline.d.ts	838	0666	edit dl rm
Pipeline.js	13423	0666	edit dl rm
Redis.d.ts	8545	0666	edit dl rm
Redis.js	30570	0666	edit dl rm
ScanStream.d.ts	569	0666	edit dl rm
ScanStream.js	1454	0666	edit dl rm
Script.d.ts	376	0666	edit dl rm
Script.js	2554	0666	edit dl rm
SubscriptionSet.d.ts	484	0666	edit dl rm
SubscriptionSet.js	1012	0666	edit dl rm
tracing.d.ts	1030	0666	edit dl rm
tracing.js	3514	0666	edit dl rm
transaction.d.ts	447	0666	edit dl rm
transaction.js	4213	0666	edit dl rm
types.d.ts	946	0666	edit dl rm
types.js	77	0666	edit dl rm

Edit: /home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/ScanStream.js (1454B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const stream_1 = require("stream");
/**
 * Convenient class to convert the process of scanning keys to a readable stream.
 */
class ScanStream extends stream_1.Readable {
    constructor(opt) {
        super(opt);
        this.opt = opt;
        this._redisCursor = "0";
        this._redisDrained = false;
    }
    _read() {
        if (this._redisDrained) {
            this.push(null);
            return;
        }
        const args = [this._redisCursor];
        if (this.opt.key) {
            args.unshift(this.opt.key);
        }
        if (this.opt.match) {
            args.push("MATCH", this.opt.match);
        }
        if (this.opt.type) {
            args.push("TYPE", this.opt.type);
        }
        if (this.opt.count) {
            args.push("COUNT", String(this.opt.count));
        }
        if (this.opt.noValues) {
            args.push("NOVALUES");
        }
        this.opt.redis[this.opt.command](args, (err, res) => {
            if (err) {
                this.emit("error", err);
                return;
            }
            this._redisCursor = res[0] instanceof Buffer ? res[0].toString() : res[0];
            if (this._redisCursor === "0") {
                this._redisDrained = true;
            }
            this.push(res[1]);
        });
    }
    close() {
        this._redisDrained = true;
    }
}
exports.default = ScanStream;

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); const stream_1 = require("stream"); /** * Convenient class to convert the process of scanning keys to a readable stream. */ class ScanStream extends stream_1.Readable { constructor(opt) { super(opt); this.opt = opt; this._redisCursor = "0"; this._redisDrained = false; } _read() { if (this._redisDrained) { this.push(null); return; } const args = [this._redisCursor]; if (this.opt.key) { args.unshift(this.opt.key); } if (this.opt.match) { args.push("MATCH", this.opt.match); } if (this.opt.type) { args.push("TYPE", this.opt.type); } if (this.opt.count) { args.push("COUNT", String(this.opt.count)); } if (this.opt.noValues) { args.push("NOVALUES"); } this.opt.redis[this.opt.command](args, (err, res) => { if (err) { this.emit("error", err); return; } this._redisCursor = res[0] instanceof Buffer ? res[0].toString() : res[0]; if (this._redisCursor === "0") { this._redisDrained = true; } this.push(res[1]); }); } close() { this._redisDrained = true; } } exports.default = ScanStream;