fix async fn

nkaradzhov · nkaradzhov · commit 33f2714442b4 · 2025-07-29T15:19:56.000+03:00
diff --git a/packages/client/lib/client/index.ts b/packages/client/lib/client/index.ts
@@ -461,12 +461,12 @@ export default class RedisClient<
     return this._self.#dirtyWatch !== undefined
   }
 
-  #resumeFromMaintenance(newSocket: RedisSocket) {
+  async #resumeFromMaintenance(newSocket: RedisSocket) {
     this._self.#socket.removeAllListeners();
     this._self.#socket.destroy();
     this._self.#socket = newSocket;
     this._self.#pausedForMaintenance = false;
-    this._self.#initiateSocket();
+    await this._self.#initiateSocket();
     this._self.#maybeScheduleWrite();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -461,12 +461,12 @@ export default class RedisClient<`
`461`	`461`	`return this._self.#dirtyWatch !== undefined`
`462`	`462`	`}`
`463`	`463`
`464`		`- #resumeFromMaintenance(newSocket: RedisSocket) {`
	`464`	`+ async #resumeFromMaintenance(newSocket: RedisSocket) {`
`465`	`465`	`this._self.#socket.removeAllListeners();`
`466`	`466`	`this._self.#socket.destroy();`
`467`	`467`	`this._self.#socket = newSocket;`
`468`	`468`	`this._self.#pausedForMaintenance = false;`
`469`		`- this._self.#initiateSocket();`
	`469`	`+ await this._self.#initiateSocket();`
`470`	`470`	`this._self.#maybeScheduleWrite();`
`471`	`471`	`}`
`472`	`472`