perf(redis): clear while scan

microlinkhq · Apr 28, 2024 · 62bd15d · 62bd15d
1 parent b1e246d
commit 62bd15d
Showing 1 changed file with 3 additions and 8 deletions.
diff --git a/packages/redis/src/index.js b/packages/redis/src/index.js
@@ -43,16 +43,11 @@ class KeyvRedis {
   async clear (namespace) {
     const match = namespace ? `${namespace}:*` : '*'
     const stream = this.redis.scanStream({ match })
-    const keys = []
-    const collectKeys = new Transform({
+    const unlinkKeys = new Transform({
       objectMode: true,
-      transform (chunk, _, next) {
-        keys.push.apply(keys, chunk)
-        next()
-      }
+      transform: (chunk, _, next) => this.redis.unlink(chunk).then(next)
     })
-    await pipeline(stream, collectKeys)
-    if (keys.length > 0) await this.redis.unlink(keys)
+    await promisify(pipeline)(stream, unlinkKeys)
   }
 
   async * iterator (namespace) {