Add experimental buffer fix for edge cases in Svelte/Preact

urql-graphql · Sep 30, 2020 · d540b0f · d540b0f
1 parent f87d4db
commit d540b0f
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/exchanges/graphcache/src/cacheExchange.ts b/exchanges/graphcache/src/cacheExchange.ts
@@ -11,13 +11,14 @@ import {
 
 import {
   filter,
+  combine,
+  scan,
   map,
   merge,
   pipe,
   share,
   fromPromise,
   fromArray,
-  buffer,
   take,
   mergeMap,
   concat,
@@ -249,10 +250,15 @@ export const cacheExchange = (opts?: CacheExchangeOpts): Exchange => ({
     // If no hydration takes place we replace this stream with an empty one
     const bufferedOps$ = hydration
       ? pipe(
-          sharedOps$,
-          buffer(fromPromise(hydration)),
+          combine(
+            pipe(
+              sharedOps$,
+              scan((acc: Operation[], x) => (acc.push(x), acc), [])
+            ),
+            fromPromise(hydration)
+          ),
           take(1),
-          mergeMap(fromArray)
+          mergeMap(zip => fromArray(zip[0]))
         )
       : (empty as Source<Operation>);