123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
import type { Connection, SendCommandOptions } from "./connection.ts";import type { RedisReply, RedisValue } from "./protocol/shared/types.ts";
export interface CommandExecutor {  readonly connection: Connection;  /**   * @deprecated   */  exec(    command: string,    ...args: RedisValue[]  ): Promise<RedisReply>;
  sendCommand(    command: string,    args?: RedisValue[],    options?: SendCommandOptions,  ): Promise<RedisReply>;
  /**   * Closes a redis connection.   */  close(): void;}
export class DefaultExecutor implements CommandExecutor {  constructor(readonly connection: Connection) {}
  exec(    command: string,    ...args: RedisValue[]  ): Promise<RedisReply> {    return this.connection.sendCommand(command, args);  }
  sendCommand(    command: string,    args?: RedisValue[],    options?: SendCommandOptions,  ) {    return this.connection.sendCommand(command, args, options);  }
  close(): void {    this.connection.close();  }}