fix: cleanup error handler to prevent memory leak (#490)

lib/index.ts

@@ -106,6 +106,7 @@ export class RedisAdapter extends Adapter {
   private requests: Map<string, Request> = new Map();
   private ackRequests: Map<string, AckRequest> = new Map();
   private redisListeners: Map<string, Function> = new Map();
+  private readonly friendlyErrorHandler: () => void;
 
   /**
    * Adapter constructor.
@@ -183,16 +184,13 @@ export class RedisAdapter extends Adapter {
       );
     }
 
-    const registerFriendlyErrorHandler = (redisClient) => {
-      redisClient.on("error", () => {
-        if (redisClient.listenerCount("error") === 1) {
-          console.warn("missing 'error' handler on this Redis client");
-        }
-      });
+    this.friendlyErrorHandler = function () {
+      if (this.listenerCount("error") === 1) {
+        console.warn("missing 'error' handler on this Redis client");
+      }
     };
-
-    registerFriendlyErrorHandler(this.pubClient);
-    registerFriendlyErrorHandler(this.subClient);
+    this.pubClient.on("error", this.friendlyErrorHandler);
+    this.subClient.on("error", this.friendlyErrorHandler);
   }
 
   /**
@@ -981,6 +979,9 @@ export class RedisAdapter extends Adapter {
         this.redisListeners.get("messageBuffer")
       );
     }
+
+    this.pubClient.off("error", this.friendlyErrorHandler);
+    this.subClient.off("error", this.friendlyErrorHandler);
   }
 }