perf(redis): clear while scan

microlinkhq · Apr 28, 2024 · f5c667d · f5c667d
1 parent b1e246d
commit f5c667d
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/packages/redis/src/index.js b/packages/redis/src/index.js
@@ -43,16 +43,14 @@ 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)
+      transform: async (chunk, _, next) => {
+        await this.redis.unlink(chunk)
         next()
       }
     })
-    await pipeline(stream, collectKeys)
-    if (keys.length > 0) await this.redis.unlink(keys)
+    await promisify(pipeline)(stream, unlinkKeys)
   }
 
   async * iterator (namespace) {