cleanup

darrachequesne · darrachequesne · commit 5e44d41c0763 · 2025-10-15T07:47:17.000+02:00
diff --git a/lib/util.ts b/lib/util.ts
@@ -82,6 +82,10 @@ export function XREAD(
   if (isRedisV5Client(redisClient)) {
     if (!redisClient[POOL]) {
       redisClient[POOL] = redisClient.createPool();
+
+      redisClient.on("end", () => {
+        redisClient[POOL].destroy();
+      });
     }
 
     return redisClient[POOL].xRead(
