use createPool with redis@5

Author: darrachequesne

lib/util.ts

@@ -57,6 +57,8 @@ function mapResult(result) {
   };
 }
 
+const POOL = Symbol("redis-v5-pool");
+
 /**
  * @see https://redis.io/commands/xread/
  */
@@ -68,6 +70,28 @@ export function XREAD(
   blockTimeInMs: number
 ) {
   if (isNodeRedisClient(redisClient)) {
+    if (typeof redisClient.createPool === "function") {
+      if (!redisClient[POOL]) {
+        redisClient[POOL] = redisClient.createPool();
+
+        redisClient.on("end", () => {
+          redisClient[POOL].destroy();
+        });
+      }
+
+      return redisClient[POOL].xRead(
+        [
+          {
+            key: streamName,
+            id: offset,
+          },
+        ],
+        {
+          COUNT: readCount,
+          BLOCK: blockTimeInMs,
+        }
+      );
+    }
     return redisClient.xRead(
       [
         {