Await on redis.subscribe() to ensure that the method returns only after Redis has acknowledged the registration of the subscriber.

Author: ifullgaz

src/transports/redis.ts

@@ -89,11 +89,7 @@ export class RedisTransport implements Transport {
     channel: string,
     handler: SubscribeHandler<T>
   ): Promise<void> {
-    this.#subscriber.subscribe(channel, (err) => {
-      if (err) {
-        throw err
-      }
-    })
+    await this.#subscriber.subscribe(channel)
 
     const event = this.#useMessageBuffer ? 'messageBuffer' : 'message'
     this.#subscriber.on(event, (receivedChannel: Buffer | string, message: Buffer | string) => {