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