fix: release deferred batch requests after each run

src/utils.ts

@@ -39,7 +39,7 @@ export function deferAndCombine<T, U>(
   timeout: number,
   runNowFn?: (arg: U) => void
 ): (arg?: U) => Promise<T> {
-  const requests: {
+  let requests: {
     resolve: (value: T | PromiseLike<T>) => void;
     reject: (reason?: unknown) => void;
   }[] = [];
@@ -58,14 +58,17 @@ export function deferAndCombine<T, U>(
 
       setTimeout(() => {
         isWaiting = false;
-        fn(requests.length)
+        const pendingRequests = requests;
+        requests = [];
+
+        fn(pendingRequests.length)
           .then((value) => {
-            for (const d of requests) {
+            for (const d of pendingRequests) {
               d.resolve(value);
             }
           })
           .catch((error) => {
-            for (const d of requests) {
+            for (const d of pendingRequests) {
               d.reject(error);
             }
           });

test/utils.spec.ts

@@ -66,6 +66,32 @@ describe('utils', function () {
       },
       deferTime * 4
     );
+
+    it(
+      'should reset requestCount across batches',
+      async function () {
+        const requestCounts: number[] = [];
+        deferredFn = deferAndCombine((requestCount) => {
+          requestCounts.push(requestCount);
+          return Promise.resolve(requestCount);
+        }, deferTime);
+
+        const resultsOne = await Promise.all([
+          deferredFn(),
+          deferredFn(),
+          deferredFn(),
+        ]);
+
+        await delay(deferTime);
+
+        const resultsTwo = await Promise.all([deferredFn(), deferredFn()]);
+
+        expect(requestCounts).toEqual([3, 2]);
+        expect(resultsOne).toEqual([3, 3, 3]);
+        expect(resultsTwo).toEqual([2, 2]);
+      },
+      deferTime * 4
+    );
   });
 
   describe('lookup', function () {