FM / built

/opt/canhelp/node_modules/ioredis/built/

/opt/canhelp/node_modules/ioredis/built

Name	Size	Mode	Actions
cluster/	-	0755	rm
connectors/	-	0755	rm
constants/	-	0755	rm
errors/	-	0755	rm
redis/	-	0755	rm
utils/	-	0755	rm
autoPipelining.d.ts	625	0644	edit dl rm
autoPipelining.js	6817	0644	edit dl rm
Command.d.ts	5326	0644	edit dl rm
Command.js	14973	0644	edit dl rm
DataHandler.d.ts	1170	0644	edit dl rm
DataHandler.js	8468	0644	edit dl rm
index.d.ts	1373	0644	edit dl rm
index.js	2570	0644	edit dl rm
Pipeline.d.ts	838	0644	edit dl rm
Pipeline.js	12990	0644	edit dl rm
Redis.d.ts	8243	0644	edit dl rm
Redis.js	28302	0644	edit dl rm
ScanStream.d.ts	569	0644	edit dl rm
ScanStream.js	1454	0644	edit dl rm
Script.d.ts	376	0644	edit dl rm
Script.js	2554	0644	edit dl rm
SubscriptionSet.d.ts	484	0644	edit dl rm
SubscriptionSet.js	1012	0644	edit dl rm
transaction.d.ts	447	0644	edit dl rm
transaction.js	3748	0644	edit dl rm
types.d.ts	946	0644	edit dl rm
types.js	77	0644	edit dl rm

Edit: /opt/canhelp/node_modules/ioredis/built/SubscriptionSet.js (1012B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
/**
 * Tiny class to simplify dealing with subscription set
 */
class SubscriptionSet {
    constructor() {
        this.set = {
            subscribe: {},
            psubscribe: {},
            ssubscribe: {},
        };
    }
    add(set, channel) {
        this.set[mapSet(set)][channel] = true;
    }
    del(set, channel) {
        delete this.set[mapSet(set)][channel];
    }
    channels(set) {
        return Object.keys(this.set[mapSet(set)]);
    }
    isEmpty() {
        return (this.channels("subscribe").length === 0 &&
            this.channels("psubscribe").length === 0 &&
            this.channels("ssubscribe").length === 0);
    }
}
exports.default = SubscriptionSet;
function mapSet(set) {
    if (set === "unsubscribe") {
        return "subscribe";
    }
    if (set === "punsubscribe") {
        return "psubscribe";
    }
    if (set === "sunsubscribe") {
        return "ssubscribe";
    }
    return set;
}

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); /** * Tiny class to simplify dealing with subscription set */ class SubscriptionSet { constructor() { this.set = { subscribe: {}, psubscribe: {}, ssubscribe: {}, }; } add(set, channel) { this.set[mapSet(set)][channel] = true; } del(set, channel) { delete this.set[mapSet(set)][channel]; } channels(set) { return Object.keys(this.set[mapSet(set)]); } isEmpty() { return (this.channels("subscribe").length === 0 && this.channels("psubscribe").length === 0 && this.channels("ssubscribe").length === 0); } } exports.default = SubscriptionSet; function mapSet(set) { if (set === "unsubscribe") { return "subscribe"; } if (set === "punsubscribe") { return "psubscribe"; } if (set === "sunsubscribe") { return "ssubscribe"; } return set; }