Fix pipelined set

soundxyz · Aug 8, 2022 · 662d8d1 · 662d8d1
1 parent 48a6a64
commit 662d8d1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/.changeset/four-pillows-run.md b/.changeset/four-pillows-run.md
@@ -0,0 +1,5 @@
+---
+"@soundxyz/fine-grained-cache": patch
+---
+
+Fix pipelined set
diff --git a/src/fineGrained.ts b/src/fineGrained.ts
@@ -287,7 +287,7 @@ export function FineGrainedCache({
     }
   }
 
-  let pendingRedisSets: { key: string; promise: DeferredPromise<void>; ttl?: number }[] = [];
+  let pendingRedisSets: { key: string; promise: DeferredPromise<void>; value: string; ttl?: number }[] = [];
 
   let pendingRedisSetTimeout: ReturnType<typeof setTimeout> | undefined;
 
@@ -306,6 +306,7 @@ export function FineGrainedCache({
       key,
       promise,
       ttl,
+      value
     });
 
     pendingRedisSetTimeout = setTimeout(executePipeline);
@@ -328,7 +329,7 @@ export function FineGrainedCache({
           | [cmd: "setex", key: string, ttl: number, value: string]
         >;
       }>(
-        (acc, { key, promise, ttl }, index) => {
+        (acc, { key, promise, ttl, value }, index) => {
           acc.promises[index] = {
             promise,
             index,