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/DataHandler.d.ts (1170B)

/// <reference types="node" />
import { NetStream, CommandItem } from "./types";
import Deque = require("denque");
import { EventEmitter } from "events";
import SubscriptionSet from "./SubscriptionSet";
export interface Condition {
    select: number;
    auth?: string | [string, string];
    subscriber: false | SubscriptionSet;
}
export declare type FlushQueueOptions = {
    offlineQueue?: boolean;
    commandQueue?: boolean;
};
export interface DataHandledable extends EventEmitter {
    stream: NetStream;
    status: string;
    condition: Condition | null;
    commandQueue: Deque<CommandItem>;
    disconnect(reconnect: boolean): void;
    recoverFromFatalError(commandError: Error, err: Error, options: FlushQueueOptions): void;
    handleReconnection(err: Error, item: CommandItem): void;
}
interface ParserOptions {
    stringNumbers: boolean;
}
export default class DataHandler {
    private redis;
    constructor(redis: DataHandledable, parserOptions: ParserOptions);
    private returnFatalError;
    private returnError;
    private returnReply;
    private handleSubscriberReply;
    private handleMonitorReply;
    private shiftCommand;
}
export {};

/// import { NetStream, CommandItem } from "./types"; import Deque = require("denque"); import { EventEmitter } from "events"; import SubscriptionSet from "./SubscriptionSet"; export interface Condition { select: number; auth?: string | [string, string]; subscriber: false | SubscriptionSet; } export declare type FlushQueueOptions = { offlineQueue?: boolean; commandQueue?: boolean; }; export interface DataHandledable extends EventEmitter { stream: NetStream; status: string; condition: Condition | null; commandQueue: Deque; disconnect(reconnect: boolean): void; recoverFromFatalError(commandError: Error, err: Error, options: FlushQueueOptions): void; handleReconnection(err: Error, item: CommandItem): void; } interface ParserOptions { stringNumbers: boolean; } export default class DataHandler { private redis; constructor(redis: DataHandledable, parserOptions: ParserOptions); private returnFatalError; private returnError; private returnReply; private handleSubscriberReply; private handleMonitorReply; private shiftCommand; } export {};