fix typo

nkaradzhov · nkaradzhov · commit cedc0ddc4552 · 2025-07-28T13:06:31.000+03:00
diff --git a/packages/client/lib/client/commands-queue.ts b/packages/client/lib/client/commands-queue.ts
@@ -79,7 +79,7 @@ export default class RedisCommandsQueue {
     this.decoder = this.#initiateDecoder();
     const [waitingForReply, emptyEmitter] = makeEmptyAware(new SinglyLinkedList<CommandWaitingForReply>())
     this.#waitingForReply = waitingForReply;
-    emptyEmitter.on('empty', this.events.on.bind(this.events, 'waitingForReplyEmpty'))
+    emptyEmitter.on('empty', this.events.emit.bind(this.events, 'waitingForReplyEmpty'))
   }
 
   #onReply(reply: ReplyUnion) {

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ export default class RedisCommandsQueue {`
`79`	`79`	`this.decoder = this.#initiateDecoder();`
`80`	`80`	`const [waitingForReply, emptyEmitter] = makeEmptyAware(new SinglyLinkedList<CommandWaitingForReply>())`
`81`	`81`	`this.#waitingForReply = waitingForReply;`
`82`		`- emptyEmitter.on('empty', this.events.on.bind(this.events, 'waitingForReplyEmpty'))`
	`82`	`+ emptyEmitter.on('empty', this.events.emit.bind(this.events, 'waitingForReplyEmpty'))`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`#onReply(reply: ReplyUnion) {`