From e43a9b2e5393e6c20e83e62847ab71b1464e2c0e Mon Sep 17 00:00:00 2001 From: uki00a Date: Wed, 18 Oct 2023 20:58:58 +0900 Subject: [PATCH] fix --- connection.ts | 7 ++++--- protocol/mod.ts | 1 - 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/connection.ts b/connection.ts index b6218aed..1faa37a7 100644 --- a/connection.ts +++ b/connection.ts @@ -1,5 +1,6 @@ import { readReply, sendCommand, sendCommands } from "./protocol/mod.ts"; -import type { Command, RedisReply, RedisValue } from "./protocol/mod.ts"; +import type { RedisReply, RedisValue } from "./protocol/mod.ts"; +import type { Command } from "./protocol/command.ts"; import type { Backoff } from "./backoff.ts"; import { exponentialBackoff } from "./backoff.ts"; import { ErrorReplyError, isRetriableError } from "./errors.ts"; @@ -64,7 +65,7 @@ export interface RedisConnectionOptions { export const kEmptyRedisArgs: Array = []; -interface Command { +interface PendingCommand { name: string; args: RedisValue[]; promise: Deferred; @@ -84,7 +85,7 @@ export class RedisConnection implements Connection { private _isConnected = false; private backoff: Backoff; - private commandQueue: Command[] = []; + private commandQueue: PendingCommand[] = []; get isClosed(): boolean { return this._isClosed; diff --git a/protocol/mod.ts b/protocol/mod.ts index 567f8251..fdda90cf 100644 --- a/protocol/mod.ts +++ b/protocol/mod.ts @@ -14,5 +14,4 @@ export type { export { okReply, readArrayReply, readReply } from "./reply.ts"; -export type { Command } from "./command.ts"; export { sendCommand, sendCommands } from "./command.ts";