@keyvhq/redis - npm Package Compare versions

Comparing version 2.1.3 to 2.1.4

package.json

@@ -5,3 +5,3 @@ {
   "homepage": "https://github.com/microlinkhq/keyv",
-  "version": "2.1.3",
+  "version": "2.1.4",
   "types": "./src/index.d.ts",
@@ -65,3 +65,3 @@ "main": "src/index.js",
   },
-  "gitHead": "b1e246d8e3eda5bf2685dabbb391b023e7078575"
+  "gitHead": "eb16570ac0f0a1fb836352b4e5088e601ef8cb3b"
 }

src/index.js

@@ -46,12 +46,7 @@ 'use strict'
     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: (keys, _, next) => keys.length > 0 ? this.redis.unlink(keys).then(() => next()) : next()
     })
-    await pipeline(stream, collectKeys)
-    if (keys.length > 0) await this.redis.unlink(keys)
+    await promisify(pipeline)(stream, unlinkKeys)
   }
@@ -58,0 +53,0 @@

No alert changes

Worsened metrics

Total package byte prevSize

7050

-0.77%

Lines of code

85

-5.56%

No dependency changes