Skip to main content
Module

x/redis/pipeline.ts>PipelineExecutor

🦕 Redis client for Deno 🍕
denodrivers/redis
Very Popular
Go to Latest
class PipelineExecutor
implements CommandExecutor
import { PipelineExecutor } from "https://deno.land/x/redis@v0.32.2/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(): void
close(): void
exec(command: string, ...args: RedisValue[]): Promise<RedisReply>
flush(): Promise<RawOrError[]>
sendCommand(
command: string,
args?: RedisValue[],
): Promise<RedisReply>