class PipelineExecutor
implements CommandExecutor
import { PipelineExecutor } from "https://deno.land/x/redis@v0.29.2/pipeline.ts";
Constructors
new
PipelineExecutor(connection: Connection, tx: boolean)Properties
private
commands: { command: string; args: RedisValue[]; }[]private
queue: { commands: { command: string; args: RedisValue[]; }[]; d: Deferred<RawOrError[]>; }[]Methods
private
dequeue(): voidclose(): void
exec(command: string, ...args: RedisValue[]): Promise<RedisReply>
flush(): Promise<RawOrError[]>