@logtail/tools - npm Package Compare versions

Comparing version 0.4.21 to 0.5.0

dist/cjs/batch.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.calculateJsonLogSizeBytes = void 0;
+exports.default = makeBatch;
 /*
@@ -56,4 +57,4 @@ * Default buffer size
         try {
-            await cb(currentBuffer.map(d => d.log));
-            currentBuffer.forEach(d => d.resolve(d.log));
+            await cb(currentBuffer.map((d) => d.log));
+            currentBuffer.forEach((d) => d.resolve(d.log));
             retry = 0;
@@ -70,3 +71,3 @@ }
             }
-            currentBuffer.map(d => d.reject(e));
+            currentBuffer.map((d) => d.reject(e));
             retry = 0;
@@ -82,3 +83,3 @@ }
         }
-        return new Promise(resolve => {
+        return new Promise((resolve) => {
             timeout = setTimeout(async function () {
@@ -124,3 +125,2 @@ await flush();
 }
-exports.default = makeBatch;
 //# sourceMappingURL=batch.js.map

dist/cjs/batch.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"batch.js","sourceRoot":"","sources":["../../src/batch.ts"],"names":[],"mappings":";;;AAaA;;GAEG;AACH,MAAM,mBAAmB,GAAG,IAAI,CAAC;AAEjC;;GAEG;AACH,MAAM,qBAAqB,GAAG,IAAI,CAAC;AAEnC;;GAEG;AACH,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAE9B;;GAEG;AACH,MAAM,qBAAqB,GAAG,GAAG,CAAC;AAElC;;GAEG;AACI,MAAM,yBAAyB,GAAG,CAAC,GAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;AAAjF,QAAA,yBAAyB,6BAAwD;AAE9F;;;;;;;;;GASG;AACH,SAAwB,SAAS,CAC/B,OAAe,mBAAmB,EAClC,eAAuB,qBAAqB,EAC5C,aAAqB,mBAAmB,EACxC,eAAuB,qBAAqB,EAC5C,YAAoB,CAAC,EACrB,wBAAsD,iCAAyB;IAE/E,IAAI,OAA8B,CAAC;IACnC,IAAI,EAAY,CAAC;IACjB,IAAI,MAAM,GAAc,EAAE,CAAC;IAC3B,IAAI,eAAe,GAAG,CAAC,CAAC;IACxB,IAAI,KAAK,GAAW,CAAC,CAAC;IACtB,uEAAuE;IACvE,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC;;OAEG;IACH,KAAK,UAAU,KAAK;QAClB,IAAI,OAAO,EAAE;YACX,YAAY,CAAC,OAAO,CAAC,CAAC;SACvB;QACD,OAAO,GAAG,IAAI,CAAC;QAEf,MAAM,aAAa,GAAG,MAAM,CAAC;QAC7B,MAAM,mBAAmB,GAAG,eAAe,CAAC;QAC5C,MAAM,GAAG,EAAE,CAAC;QACZ,eAAe,GAAG,CAAC,CAAC;QAEpB,IAAI;YACF,MAAM,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACxC,aAAa,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC7C,KAAK,GAAG,CAAC,CAAC;SACX;QAAC,OAAO,CAAC,EAAE;YACV,IAAI,KAAK,GAAG,UAAU,EAAE;gBACtB,KAAK,EAAE,CAAC;gBACR,eAAe,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAC;gBAC5C,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,aAAa,CAAC,CAAC;gBACtC,eAAe,IAAI,mBAAmB,CAAC;gBACvC,MAAM,YAAY,EAAE,CAAC;gBACrB,OAAO;aACR;YACD,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;YACpC,KAAK,GAAG,CAAC,CAAC;SACX;IACH,CAAC;IAED;;OAEG;IACH,KAAK,UAAU,YAAY;QACzB,IAAI,OAAO,EAAE;YACX,OAAO;SACR;QAED,OAAO,IAAI,OAAO,CAAO,OAAO,CAAC,EAAE;YACjC,OAAO,GAAG,UAAU,CAAC,KAAK;gBACxB,MAAM,KAAK,EAAE,CAAC;gBACd,OAAO,EAAE,CAAC;YACZ,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,OAAO;QACL,UAAU,EAAE,UAAS,EAAY;YAC/B,EAAE,GAAG,EAAE,CAAC;YAER;;;eAGG;YACH,OAAO,KAAK,WAAU,GAAgB;gBACpC,OAAO,IAAI,OAAO,CAAc,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxD,MAAM,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,MAAM,EAAE,CAAC,CAAC;oBACtC,+DAA+D;oBAC/D,IAAI,SAAS,GAAG,CAAC,EAAE;wBACjB,eAAe,IAAI,qBAAqB,CAAC,GAAG,CAAC,CAAC;qBAC/C;oBAED,yCAAyC;oBACzC,gEAAgE;oBAChE,MAAM,kBAAkB,GAAG,MAAM,CAAC,MAAM,IAAI,IAAI,IAAI,CAAC,SAAS,GAAG,CAAC,IAAI,eAAe,IAAI,SAAS,CAAC,CAAC;oBACpG,IAAI,kBAAkB,IAAI,IAAI,CAAC,GAAG,EAAE,GAAG,eAAe,EAAE;wBACtD,MAAM,KAAK,EAAE,CAAC;qBACf;yBAAM;wBACL,MAAM,YAAY,EAAE,CAAC;qBACtB;oBAED,OAAO,OAAO,CAAC;gBACjB,CAAC,CAAC,CAAC;YACL,CAAC,CAAC;QACJ,CAAC;QACD,KAAK;KACN,CAAC;AACJ,CAAC;AAlGD,4BAkGC"}
+{"version":3,"file":"batch.js","sourceRoot":"","sources":["../../src/batch.ts"],"names":[],"mappings":";;;AAgDA,4BAkGC;AArID;;GAEG;AACH,MAAM,mBAAmB,GAAG,IAAI,CAAC;AAEjC;;GAEG;AACH,MAAM,qBAAqB,GAAG,IAAI,CAAC;AAEnC;;GAEG;AACH,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAE9B;;GAEG;AACH,MAAM,qBAAqB,GAAG,GAAG,CAAC;AAElC;;GAEG;AACI,MAAM,yBAAyB,GAAG,CAAC,GAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;AAAjF,QAAA,yBAAyB,6BAAwD;AAE9F;;;;;;;;;GASG;AACH,SAAwB,SAAS,CAC/B,OAAe,mBAAmB,EAClC,eAAuB,qBAAqB,EAC5C,aAAqB,mBAAmB,EACxC,eAAuB,qBAAqB,EAC5C,YAAoB,CAAC,EACrB,wBAAsD,iCAAyB;IAE/E,IAAI,OAA8B,CAAC;IACnC,IAAI,EAAY,CAAC;IACjB,IAAI,MAAM,GAAc,EAAE,CAAC;IAC3B,IAAI,eAAe,GAAG,CAAC,CAAC;IACxB,IAAI,KAAK,GAAW,CAAC,CAAC;IACtB,uEAAuE;IACvE,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC;;OAEG;IACH,KAAK,UAAU,KAAK;QAClB,IAAI,OAAO,EAAE,CAAC;YACZ,YAAY,CAAC,OAAO,CAAC,CAAC;QACxB,CAAC;QACD,OAAO,GAAG,IAAI,CAAC;QAEf,MAAM,aAAa,GAAG,MAAM,CAAC;QAC7B,MAAM,mBAAmB,GAAG,eAAe,CAAC;QAC5C,MAAM,GAAG,EAAE,CAAC;QACZ,eAAe,GAAG,CAAC,CAAC;QAEpB,IAAI,CAAC;YACH,MAAM,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC1C,aAAa,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC/C,KAAK,GAAG,CAAC,CAAC;QACZ,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,IAAI,KAAK,GAAG,UAAU,EAAE,CAAC;gBACvB,KAAK,EAAE,CAAC;gBACR,eAAe,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAC;gBAC5C,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,aAAa,CAAC,CAAC;gBACtC,eAAe,IAAI,mBAAmB,CAAC;gBACvC,MAAM,YAAY,EAAE,CAAC;gBACrB,OAAO;YACT,CAAC;YACD,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;YACtC,KAAK,GAAG,CAAC,CAAC;QACZ,CAAC;IACH,CAAC;IAED;;OAEG;IACH,KAAK,UAAU,YAAY;QACzB,IAAI,OAAO,EAAE,CAAC;YACZ,OAAO;QACT,CAAC;QAED,OAAO,IAAI,OAAO,CAAO,CAAC,OAAO,EAAE,EAAE;YACnC,OAAO,GAAG,UAAU,CAAC,KAAK;gBACxB,MAAM,KAAK,EAAE,CAAC;gBACd,OAAO,EAAE,CAAC;YACZ,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,OAAO;QACL,UAAU,EAAE,UAAU,EAAY;YAChC,EAAE,GAAG,EAAE,CAAC;YAER;;;eAGG;YACH,OAAO,KAAK,WAAW,GAAgB;gBACrC,OAAO,IAAI,OAAO,CAAc,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxD,MAAM,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,MAAM,EAAE,CAAC,CAAC;oBACtC,+DAA+D;oBAC/D,IAAI,SAAS,GAAG,CAAC,EAAE,CAAC;wBAClB,eAAe,IAAI,qBAAqB,CAAC,GAAG,CAAC,CAAC;oBAChD,CAAC;oBAED,yCAAyC;oBACzC,gEAAgE;oBAChE,MAAM,kBAAkB,GAAG,MAAM,CAAC,MAAM,IAAI,IAAI,IAAI,CAAC,SAAS,GAAG,CAAC,IAAI,eAAe,IAAI,SAAS,CAAC,CAAC;oBACpG,IAAI,kBAAkB,IAAI,IAAI,CAAC,GAAG,EAAE,GAAG,eAAe,EAAE,CAAC;wBACvD,MAAM,KAAK,EAAE,CAAC;oBAChB,CAAC;yBAAM,CAAC;wBACN,MAAM,YAAY,EAAE,CAAC;oBACvB,CAAC;oBAED,OAAO,OAAO,CAAC;gBACjB,CAAC,CAAC,CAAC;YACL,CAAC,CAAC;QACJ,CAAC;QACD,KAAK;KACN,CAAC;AACJ,CAAC"}

dist/cjs/batch.test.js

@@ -72,3 +72,3 @@ "use strict";
             .get("/")
-            .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+            .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
         const called = jest.fn();
@@ -87,3 +87,3 @@ const size = 5;
         });
-        await Promise.all(logNumberTimes(logger, 5)).catch(e => {
+        await Promise.all(logNumberTimes(logger, 5)).catch((e) => {
             throw e;
@@ -105,3 +105,3 @@ });
         });
-        await Promise.all(logNumberTimes(logger, 5)).catch(e => { });
+        await Promise.all(logNumberTimes(logger, 5)).catch((e) => { });
         expect(called).toHaveBeenCalledTimes(4); // 3 retries + 1 initial
@@ -121,3 +121,3 @@ });
         });
-        logger(getRandomLog()).catch(e => { });
+        logger(getRandomLog()).catch((e) => { });
         await batcher.flush();
@@ -136,3 +136,3 @@ expect(called).toHaveBeenCalledTimes(4); // 3 retries + 1 initial
         const throttler = throttle(async (logs) => {
-            return new Promise(resolve => {
+            return new Promise((resolve) => {
                 setTimeout(() => resolve(logs), throttleResolveAfter);
@@ -162,3 +162,4 @@ });
         const expectedTime = ((numberOfLogs / batchSize) * throttleResolveAfter) / maxThrottle;
-        expect(end).toBeGreaterThanOrEqual(expectedTime);
+        const toleranceMilliseconds = 0.2;
+        expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
     });
@@ -168,3 +169,3 @@ it("should send after flush (with long timeout)", async () => {
             .get("/")
-            .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+            .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
         const called = jest.fn();
@@ -207,3 +208,3 @@ const size = 50;
         // 100 logs with 50B each is 5000B in total - expecting 10 batches of 500B
-        await Promise.all(logNumberTimes(logger, 100)).catch(e => {
+        await Promise.all(logNumberTimes(logger, 100)).catch((e) => {
             throw e;
@@ -210,0 +211,0 @@ });

dist/cjs/batch.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"batch.test.js","sourceRoot":"","sources":["../../src/batch.test.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,gDAAwB;AACxB,8DAAgC;AAChC,0CAAuD;AACvD,iDAA+D;AAC/D,0DAAsC;AAEtC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED;;;;;GAKG;AACH,SAAS,cAAc,CAAC,MAAgB,EAAE,CAAS;IACjD,OAAO,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;AAChE,CAAC;AAED;;;GAGG;AACH,SAAS,WAAW,CAAC,KAAuB;IAC1C,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAClC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,GAAG,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC;AACvC,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,UAAU,CAAC,GAAG,EAAE;QACd,cAAI,CAAC,OAAO,EAAE,CAAC;QACf,cAAI,CAAC,QAAQ,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;IACH,SAAS,CAAC,GAAG,EAAE;QACb,cAAI,CAAC,OAAO,EAAE,CAAC;IACjB,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,qDAAqD,EAAE,KAAK,IAAI,EAAE;QACnE,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEpE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QAEvB,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI;gBACF,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;aACnC;YAAC,OAAO,CAAC,EAAE;gBACV,MAAM,CAAC,CAAC;aACT;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE;YACrD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,uBAAuB,EAAE,KAAK,IAAI,EAAE;QACrC,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,GAAE,CAAC,CAAC,CAAC;QAC5D,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,GAAE,CAAC,CAAC,CAAC;QACtC,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,oCAAoC,EAAE,KAAK,IAAI,EAAE;QAClD,WAAW;QACX,MAAM,WAAW,GAAG,CAAC,CAAC;QACtB,MAAM,oBAAoB,GAAG,IAAI,CAAC,CAAC,KAAK;QACxC,MAAM,SAAS,GAAG,CAAC,CAAC;QACpB,MAAM,YAAY,GAAG,EAAE,CAAC;QAExB,sDAAsD;QACtD,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAC,WAAW,CAAC,CAAC;QAE3C,uCAAuC;QACvC,MAAM,SAAS,GAAG,QAAQ,CAAC,KAAK,EAAC,IAAI,EAAC,EAAE;YACtC,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;gBAC3B,UAAU,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,oBAAoB,CAAC,CAAC;YACxD,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;QAEH,2CAA2C;QAC3C,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,uDAAuD;QACvD,MAAM,KAAK,GAAG,IAAA,eAAS,EAAC,SAAS,EAAE,IAAI,CAAC,CAAC;QAEzC,kCAAkC;QAClC,MAAM,OAAO,GAAG,KAAK,CAAC,UAAU,CAAC,CAAC,IAAS,EAAE,EAAE;YAC7C,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;YACvC,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACzB,CAAC,CAAC,CAAC;QAEH,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,4CAA4C;QAC5C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,YAAY,EAAE,CAAC,EAAE,EAAE;YACrC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;SACxC;QAED,gCAAgC;QAChC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,qDAAqD;QACrD,MAAM,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,CAAC;QAE/B,kDAAkD;QAClD,MAAM,YAAY,GAAG,CAAC,CAAC,YAAY,GAAG,SAAS,CAAC,GAAG,oBAAoB,CAAC,GAAG,WAAW,CAAC;QAEvF,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,CAAC,CAAC;IACnD,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6CAA6C,EAAE,KAAK,IAAI,EAAE;QAC3D,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEpE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAChB,MAAM,WAAW,GAAG,KAAK,CAAC;QAE1B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI;gBACF,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;aACnC;YAAC,OAAO,CAAC,EAAE;gBACV,MAAM,CAAC,CAAC;aACT;QACH,CAAC,CAAC,CAAC;QAEH,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QAC1B,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QACxC,IAAI;YACF,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;SACvB;QAAC,OAAO,CAAC,EAAE;YACV,MAAM,CAAC,CAAC;SACT;QACD,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,4CAA4C,EAAE,KAAK,IAAI,EAAE;QAC1D,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,MAAM,WAAW,GAAG,IAAI,CAAC;QACzB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QAEvB,6DAA6D;QAC7D,MAAM,SAAS,GAAG,GAAG,CAAC;QACtB,MAAM,aAAa,GAAG,CAAC,IAAiB,EAAE,EAAE,CAAC,EAAE,CAAC;QAEhD,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QACjG,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,MAAqB,EAAE,EAAE;YAChE,MAAM,EAAE,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,0EAA0E;QAC1E,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE;YACvD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEH,QAAQ,CAAC,0BAA0B,EAAE,GAAG,EAAE;IACxC,EAAE,CAAC,0CAA0C,EAAE,KAAK,IAAI,EAAE;QACxD,MAAM,GAAG,GAAgB;YACvB,EAAE,EAAE,IAAI,IAAI,EAAE;YACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;YACpB,OAAO,EAAE,YAAY;SACtB,CAAC;QAEF,MAAM,kBAAkB,GAAG,IAAA,iCAAyB,EAAC,GAAG,CAAC,CAAC;QAC1D,MAAM,oBAAoB,GAAG,0EAA0E,CAAC,MAAM,CAAC;QAE/G,MAAM,CAAC,kBAAkB,CAAC,CAAC,OAAO,CAAC,oBAAoB,CAAC,CAAC;IAC3D,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"batch.test.js","sourceRoot":"","sources":["../../src/batch.test.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,gDAAwB;AACxB,8DAAgC;AAChC,0CAAuD;AACvD,iDAA+D;AAC/D,0DAAsC;AAEtC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED;;;;;GAKG;AACH,SAAS,cAAc,CAAC,MAAgB,EAAE,CAAS;IACjD,OAAO,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;AAChE,CAAC;AAED;;;GAGG;AACH,SAAS,WAAW,CAAC,KAAuB;IAC1C,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAClC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,GAAG,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC;AACvC,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,UAAU,CAAC,GAAG,EAAE;QACd,cAAI,CAAC,OAAO,EAAE,CAAC;QACf,cAAI,CAAC,QAAQ,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;IACH,SAAS,CAAC,GAAG,EAAE;QACb,cAAI,CAAC,OAAO,EAAE,CAAC;IACjB,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,qDAAqD,EAAE,KAAK,IAAI,EAAE;QACnE,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEtE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QAEvB,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI,CAAC;gBACH,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;YACpC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,MAAM,CAAC,CAAC;YACV,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE;YACvD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,uBAAuB,EAAE,KAAK,IAAI,EAAE;QACrC,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE,GAAE,CAAC,CAAC,CAAC;QAC9D,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE,GAAE,CAAC,CAAC,CAAC;QACxC,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,oCAAoC,EAAE,KAAK,IAAI,EAAE;QAClD,WAAW;QACX,MAAM,WAAW,GAAG,CAAC,CAAC;QACtB,MAAM,oBAAoB,GAAG,IAAI,CAAC,CAAC,KAAK;QACxC,MAAM,SAAS,GAAG,CAAC,CAAC;QACpB,MAAM,YAAY,GAAG,EAAE,CAAC;QAExB,sDAAsD;QACtD,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAC,WAAW,CAAC,CAAC;QAE3C,uCAAuC;QACvC,MAAM,SAAS,GAAG,QAAQ,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE;YACxC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE;gBAC7B,UAAU,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,oBAAoB,CAAC,CAAC;YACxD,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;QAEH,2CAA2C;QAC3C,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,uDAAuD;QACvD,MAAM,KAAK,GAAG,IAAA,eAAS,EAAC,SAAS,EAAE,IAAI,CAAC,CAAC;QAEzC,kCAAkC;QAClC,MAAM,OAAO,GAAG,KAAK,CAAC,UAAU,CAAC,CAAC,IAAS,EAAE,EAAE;YAC7C,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;YACvC,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACzB,CAAC,CAAC,CAAC;QAEH,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,4CAA4C;QAC5C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,YAAY,EAAE,CAAC,EAAE,EAAE,CAAC;YACtC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;QACzC,CAAC;QAED,gCAAgC;QAChC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,qDAAqD;QACrD,MAAM,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,CAAC;QAE/B,kDAAkD;QAClD,MAAM,YAAY,GAAG,CAAC,CAAC,YAAY,GAAG,SAAS,CAAC,GAAG,oBAAoB,CAAC,GAAG,WAAW,CAAC;QACvF,MAAM,qBAAqB,GAAG,GAAG,CAAC;QAElC,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,GAAG,qBAAqB,CAAC,CAAC;IAC3E,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6CAA6C,EAAE,KAAK,IAAI,EAAE;QAC3D,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEtE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAChB,MAAM,WAAW,GAAG,KAAK,CAAC;QAE1B,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI,CAAC;gBACH,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;YACpC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,MAAM,CAAC,CAAC;YACV,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QAC1B,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QACxC,IAAI,CAAC;YACH,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QACxB,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,MAAM,CAAC,CAAC;QACV,CAAC;QACD,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,4CAA4C,EAAE,KAAK,IAAI,EAAE;QAC1D,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,MAAM,WAAW,GAAG,IAAI,CAAC;QACzB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QAEvB,6DAA6D;QAC7D,MAAM,SAAS,GAAG,GAAG,CAAC;QACtB,MAAM,aAAa,GAAG,CAAC,IAAiB,EAAE,EAAE,CAAC,EAAE,CAAC;QAEhD,MAAM,OAAO,GAAG,IAAA,eAAS,EAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QACjG,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,MAAqB,EAAE,EAAE;YAChE,MAAM,EAAE,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,0EAA0E;QAC1E,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE;YACzD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEH,QAAQ,CAAC,0BAA0B,EAAE,GAAG,EAAE;IACxC,EAAE,CAAC,0CAA0C,EAAE,KAAK,IAAI,EAAE;QACxD,MAAM,GAAG,GAAgB;YACvB,EAAE,EAAE,IAAI,IAAI,EAAE;YACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;YACpB,OAAO,EAAE,YAAY;SACtB,CAAC;QAEF,MAAM,kBAAkB,GAAG,IAAA,iCAAyB,EAAC,GAAG,CAAC,CAAC;QAC1D,MAAM,oBAAoB,GAAG,0EAA0E,CAAC,MAAM,CAAC;QAE/G,MAAM,CAAC,kBAAkB,CAAC,CAAC,OAAO,CAAC,oBAAoB,CAAC,CAAC;IAC3D,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

dist/cjs/burstProtection.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.default = makeBurstProtection;
 const RESOLUTION = 64;
@@ -25,6 +26,3 @@ /**
         const intervalCountSinceLast = Math.floor((now - lastIntervalTime) / intervalLength);
-        callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION))
-            .fill(0)
-            .concat(callCounts)
-            .slice(0, RESOLUTION);
+        callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION)).fill(0).concat(callCounts).slice(0, RESOLUTION);
         lastIntervalTime += intervalCountSinceLast * intervalLength;
@@ -53,3 +51,2 @@ }
 }
-exports.default = makeBurstProtection;
 //# sourceMappingURL=burstProtection.js.map

dist/cjs/burstProtection.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"burstProtection.js","sourceRoot":"","sources":["../../src/burstProtection.ts"],"names":[],"mappings":";;AAEA,MAAM,UAAU,GAAG,EAAE,CAAC;AAEtB;;;;;GAKG;AACH,SAAwB,mBAAmB,CACzC,YAAoB,EACpB,GAAW,EACX,eAAuB,cAAc;IAErC,IAAI,YAAY,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,EAAE;QACjC,OAAO,CAAC,EAAK,EAAE,EAAE,CAAC,EAAE,CAAC;KACtB;IAED,IAAI,UAAU,GAAa,CAAC,CAAC,CAAC,CAAC;IAC/B,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC,IAAI,gBAAgB,GAAW,IAAI,CAAC,GAAG,EAAE,CAAC;IAE1C,SAAS,gBAAgB;QACvB,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;QACvB,MAAM,cAAc,GAAG,YAAY,GAAG,UAAU,CAAC;QAEjD,IAAI,GAAG,GAAG,gBAAgB,GAAG,cAAc,EAAE;YAC3C,OAAO;SACR;QAED,4FAA4F;QAC5F,MAAM,sBAAsB,GAAG,IAAI,CAAC,KAAK,CAAC,CAAC,GAAG,GAAG,gBAAgB,CAAC,GAAG,cAAc,CAAC,CAAC;QACrF,UAAU,GAAG,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,sBAAsB,EAAE,UAAU,CAAC,CAAC;aAC7D,IAAI,CAAC,CAAC,CAAC;aACP,MAAM,CAAC,UAAU,CAAC;aAClB,KAAK,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;QACxB,gBAAgB,IAAI,sBAAsB,GAAG,cAAc,CAAC;IAC9D,CAAC;IAED,SAAS,iBAAiB;QACxB,OAAO,UAAU,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;IAC1D,CAAC;IAED,SAAS,kBAAkB;QACzB,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC;IAClB,CAAC;IAED,OAAO,CAAC,EAAK,EAAE,EAAE;QACf,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,gBAAgB,EAAE,CAAC;YACnB,IAAI,iBAAiB,EAAE,GAAG,GAAG,EAAE;gBAC7B,kBAAkB,EAAE,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC;aAC1B;YAED,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACvB,IAAI,eAAe,GAAG,GAAG,GAAG,YAAY,EAAE;gBACxC,eAAe,GAAG,GAAG,CAAC;gBACtB,OAAO,CAAC,KAAK,CAAC,GAAG,YAAY,yBAAyB,GAAG,sBAAsB,YAAY,eAAe,CAAC,CAAC;aAC7G;QACH,CAAC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC;AArDD,sCAqDC"}
+{"version":3,"file":"burstProtection.js","sourceRoot":"","sources":["../../src/burstProtection.ts"],"names":[],"mappings":";;AAUA,sCAkDC;AA1DD,MAAM,UAAU,GAAG,EAAE,CAAC;AAEtB;;;;;GAKG;AACH,SAAwB,mBAAmB,CACzC,YAAoB,EACpB,GAAW,EACX,eAAuB,cAAc;IAErC,IAAI,YAAY,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,EAAE,CAAC;QAClC,OAAO,CAAC,EAAK,EAAE,EAAE,CAAC,EAAE,CAAC;IACvB,CAAC;IAED,IAAI,UAAU,GAAa,CAAC,CAAC,CAAC,CAAC;IAC/B,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC,IAAI,gBAAgB,GAAW,IAAI,CAAC,GAAG,EAAE,CAAC;IAE1C,SAAS,gBAAgB;QACvB,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;QACvB,MAAM,cAAc,GAAG,YAAY,GAAG,UAAU,CAAC;QAEjD,IAAI,GAAG,GAAG,gBAAgB,GAAG,cAAc,EAAE,CAAC;YAC5C,OAAO;QACT,CAAC;QAED,4FAA4F;QAC5F,MAAM,sBAAsB,GAAG,IAAI,CAAC,KAAK,CAAC,CAAC,GAAG,GAAG,gBAAgB,CAAC,GAAG,cAAc,CAAC,CAAC;QACrF,UAAU,GAAG,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,sBAAsB,EAAE,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;QACjH,gBAAgB,IAAI,sBAAsB,GAAG,cAAc,CAAC;IAC9D,CAAC;IAED,SAAS,iBAAiB;QACxB,OAAO,UAAU,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;IAC1D,CAAC;IAED,SAAS,kBAAkB;QACzB,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC;IAClB,CAAC;IAED,OAAO,CAAC,EAAK,EAAE,EAAE;QACf,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,gBAAgB,EAAE,CAAC;YACnB,IAAI,iBAAiB,EAAE,GAAG,GAAG,EAAE,CAAC;gBAC9B,kBAAkB,EAAE,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC;YAC3B,CAAC;YAED,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACvB,IAAI,eAAe,GAAG,GAAG,GAAG,YAAY,EAAE,CAAC;gBACzC,eAAe,GAAG,GAAG,CAAC;gBACtB,OAAO,CAAC,KAAK,CAAC,GAAG,YAAY,yBAAyB,GAAG,sBAAsB,YAAY,eAAe,CAAC,CAAC;YAC9G,CAAC;QACH,CAAC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC"}

dist/cjs/encode.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.base64Encode = void 0;
+exports.base64Encode = base64Encode;
 /**
@@ -12,3 +12,2 @@ * Converts a plain-text string to a base64 string
 }
-exports.base64Encode = base64Encode;
 //# sourceMappingURL=encode.js.map

dist/cjs/encode.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"encode.js","sourceRoot":"","sources":["../../src/encode.ts"],"names":[],"mappings":";;;AAAA;;;;GAIG;AACH,SAAgB,YAAY,CAAC,GAAW;IACtC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC;AAC7C,CAAC;AAFD,oCAEC"}
+{"version":3,"file":"encode.js","sourceRoot":"","sources":["../../src/encode.ts"],"names":[],"mappings":";;AAKA,oCAEC;AAPD;;;;GAIG;AACH,SAAgB,YAAY,CAAC,GAAW;IACtC,OAAO,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC;AAC7C,CAAC"}

dist/cjs/queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queue.js","sourceRoot":"","sources":["../../src/queue.ts"],"names":[],"mappings":";;AAEA;;;GAGG;AACH,MAAqB,KAAK;IAA1B;QACE;;WAEG;QAQH;;WAEG;QACI,WAAM,GAAG,CAAC,CAAC;IAyBpB,CAAC;IAvBC;;;OAGG;IACI,IAAI,CAAC,KAAU;QACpB,MAAM,IAAI,GAAG,EAAE,KAAK,EAAE,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;QACtE,IAAI,CAAC,MAAM,EAAE,CAAC;IAChB,CAAC;IAED;;OAEG;IACI,KAAK;QACV,IAAI,IAAI,CAAC,KAAK,EAAE;YACd,MAAM,EAAE,KAAK,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC;YAC7B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YAC7B,IAAI,CAAC,EAAE,IAAI,CAAC,MAAM,EAAE;gBAClB,IAAI,CAAC,IAAI,GAAG,SAAS,CAAC;aACvB;YACD,OAAO,KAAK,CAAC;SACd;IACH,CAAC;CACF;AAvCD,wBAuCC"}
+{"version":3,"file":"queue.js","sourceRoot":"","sources":["../../src/queue.ts"],"names":[],"mappings":";;AAEA;;;GAGG;AACH,MAAqB,KAAK;IAA1B;QACE;;WAEG;QAQH;;WAEG;QACI,WAAM,GAAG,CAAC,CAAC;IAyBpB,CAAC;IAvBC;;;OAGG;IACI,IAAI,CAAC,KAAU;QACpB,MAAM,IAAI,GAAG,EAAE,KAAK,EAAE,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;QACtE,IAAI,CAAC,MAAM,EAAE,CAAC;IAChB,CAAC;IAED;;OAEG;IACI,KAAK;QACV,IAAI,IAAI,CAAC,KAAK,EAAE,CAAC;YACf,MAAM,EAAE,KAAK,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC;YAC7B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YAC7B,IAAI,CAAC,EAAE,IAAI,CAAC,MAAM,EAAE,CAAC;gBACnB,IAAI,CAAC,IAAI,GAAG,SAAS,CAAC;YACxB,CAAC;YACD,OAAO,KAAK,CAAC;QACf,CAAC;IACH,CAAC;CACF;AAvCD,wBAuCC"}

dist/cjs/queue.test.js

@@ -27,3 +27,3 @@ "use strict";
         // against the values from the queue
-        list.forEach(item => {
+        list.forEach((item) => {
             expect(q.shift()).toEqual(item);
@@ -30,0 +30,0 @@ });

dist/cjs/queue.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queue.test.js","sourceRoot":"","sources":["../../src/queue.test.ts"],"names":[],"mappings":";;;;;AAAA,oDAA4B;AAE5B,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,+CAA+C,EAAE,GAAG,EAAE;QACvD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QAEzB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,yCAAyC,EAAE,GAAG,EAAE;QACjD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAEhB,2CAA2C;QAC3C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;YACb,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,oDAAoD;QACpD,oCAAoC;QACpC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAClB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAClC,CAAC,CAAC,CAAC;QAEH,4BAA4B;QAC5B,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC9B,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6BAA6B,EAAE,GAAG,EAAE;QACrC,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,MAAM,CAAC;QAE7B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,2CAA2C,EAAE,GAAG,EAAE;QACnD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IACvC,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"queue.test.js","sourceRoot":"","sources":["../../src/queue.test.ts"],"names":[],"mappings":";;;;;AAAA,oDAA4B;AAE5B,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,+CAA+C,EAAE,GAAG,EAAE;QACvD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QAEzB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,yCAAyC,EAAE,GAAG,EAAE;QACjD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAEhB,2CAA2C;QAC3C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;YACb,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,oDAAoD;QACpD,oCAAoC;QACpC,IAAI,CAAC,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE;YACpB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAClC,CAAC,CAAC,CAAC;QAEH,4BAA4B;QAC5B,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC9B,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6BAA6B,EAAE,GAAG,EAAE;QACrC,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,MAAM,CAAC;QAE7B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,2CAA2C,EAAE,GAAG,EAAE;QACnD,MAAM,CAAC,GAAG,IAAI,eAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IACvC,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

dist/cjs/retry.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.default = makeRetry;
 /**
@@ -13,3 +14,3 @@ * maximum number of tries to push logs to logtail
 function delay(sec) {
-    return new Promise(resolve => setTimeout(resolve, sec * 1000));
+    return new Promise((resolve) => setTimeout(resolve, sec * 1000));
 }
@@ -62,3 +63,2 @@ /**
 }
-exports.default = makeRetry;
 //# sourceMappingURL=retry.js.map

dist/cjs/retry.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"retry.js","sourceRoot":"","sources":["../../src/retry.ts"],"names":[],"mappings":";;AAEA;;GAEG;AACH,IAAI,SAAS,GAAG,CAAC,CAAC;AAElB;;;;GAIG;AACH,SAAS,KAAK,CAAC,GAAW;IACxB,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,UAAU,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI,CAAC,CAAC,CAAC;AACjE,CAAC;AAED;;;;GAIG;AACY,KAAK,UAAU,SAAS,CAAC,EAAmD;IACzF;;OAEG;IACH,IAAI,KAAK,GAAW,CAAC,CAAC;IAEtB;;OAEG;IACH,IAAI,QAAQ,GAAa,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAEhC;;;OAGG;IACH,OAAO,KAAK,UAAU,KAAK,CAAC,IAAmB;QAC7C,8CAA8C;QAC9C,OAAO,KAAK,EAAE,GAAG,SAAS,EAAE;YAC1B,IAAI;gBACF;;mBAEG;gBACH,MAAM,OAAO,GAAG,QAAQ;qBACrB,KAAK,EAAE;qBACP,OAAO,EAAE;qBACT,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC;qBACX,MAAM,CAAC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,CAAC,GAAG,GAAG,IAAI,EAAE,CAAC,CAAC,CAAC;gBAExC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACvB,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,IAAI,CAAC,CAAC;aACvB;YAAC,OAAO,CAAC,EAAE;gBACV;;mBAEG;gBACH,IAAI,KAAK,KAAK,SAAS,EAAE;oBACvB,MAAM,CAAC,CAAC;iBACT;aACF;SACF;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IAC/B,CAAC,CAAC;AACJ,CAAC;AA3CD,4BA2CC"}
+{"version":3,"file":"retry.js","sourceRoot":"","sources":["../../src/retry.ts"],"names":[],"mappings":";;AAqBA,4BA2CC;AA9DD;;GAEG;AACH,IAAI,SAAS,GAAG,CAAC,CAAC;AAElB;;;;GAIG;AACH,SAAS,KAAK,CAAC,GAAW;IACxB,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI,CAAC,CAAC,CAAC;AACnE,CAAC;AAED;;;;GAIG;AACY,KAAK,UAAU,SAAS,CAAC,EAAmD;IACzF;;OAEG;IACH,IAAI,KAAK,GAAW,CAAC,CAAC;IAEtB;;OAEG;IACH,IAAI,QAAQ,GAAa,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAEhC;;;OAGG;IACH,OAAO,KAAK,UAAU,KAAK,CAAC,IAAmB;QAC7C,8CAA8C;QAC9C,OAAO,KAAK,EAAE,GAAG,SAAS,EAAE,CAAC;YAC3B,IAAI,CAAC;gBACH;;mBAEG;gBACH,MAAM,OAAO,GAAG,QAAQ;qBACrB,KAAK,EAAE;qBACP,OAAO,EAAE;qBACT,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC;qBACX,MAAM,CAAC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,CAAC,GAAG,GAAG,IAAI,EAAE,CAAC,CAAC,CAAC;gBAExC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACvB,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,IAAI,CAAC,CAAC;YACxB,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX;;mBAEG;gBACH,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;oBACxB,MAAM,CAAC,CAAC;gBACV,CAAC;YACH,CAAC;QACH,CAAC;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IAC/B,CAAC,CAAC;AACJ,CAAC"}

dist/cjs/retry.test.js

@@ -39,5 +39,3 @@ "use strict";
         const logs = [getRandomLog()];
-        (0, nock_1.default)("http://example.com")
-            .get("/")
-            .reply(200, logs);
+        (0, nock_1.default)("http://example.com").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -51,7 +49,3 @@ const retry = await (0, retry_1.default)(sync);
         const logs = [getRandomLog()];
-        (0, nock_1.default)("http://example.com")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(200, logs);
+        (0, nock_1.default)("http://example.com").get("/").reply(500, "Bad").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -65,9 +59,3 @@ const retry = await (0, retry_1.default)(sync);
         const logs = [getRandomLog()];
-        (0, nock_1.default)("http://example.com")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(200, logs);
+        (0, nock_1.default)("http://example.com").get("/").reply(500, "Bad").get("/").reply(500, "Bad").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -74,0 +62,0 @@ const retry = await (0, retry_1.default)(sync);

dist/cjs/retry.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"retry.test.js","sourceRoot":"","sources":["../../src/retry.test.ts"],"names":[],"mappings":";;;;;AAAA,0CAAuD;AACvD,8DAAgC;AAChC,gDAAwB;AACxB,oDAAgC;AAEhC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED,SAAS,QAAQ,CAAC,MAAgB;IAChC,OAAO,KAAK,UAAU,IAAI,CAAC,IAAmB;QAC5C,IAAI;YACF,MAAM,GAAG,GAAG,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;YAC9C,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;aAC9B;YACD,MAAM,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC;SAC5B;QAAC,OAAO,CAAC,EAAE;YACV,MAAM,EAAE,CAAC;YACT,MAAM,CAAC,CAAC;SACT;IACH,CAAC,CAAC;AACJ,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,gCAAgC,EAAE,KAAK,IAAI,EAAE;QAC9C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,IAAI;YACF,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;SACxC;QAAC,WAAM;YACN,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;SACzC;IACH,CAAC,EAAE,IAAI,CAAC,CAAC;AACX,CAAC,CAAC,CAAC"}
+{"version":3,"file":"retry.test.js","sourceRoot":"","sources":["../../src/retry.test.ts"],"names":[],"mappings":";;;;;AAAA,0CAAuD;AACvD,8DAAgC;AAChC,gDAAwB;AACxB,oDAAgC;AAEhC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,gBAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED,SAAS,QAAQ,CAAC,MAAgB;IAChC,OAAO,KAAK,UAAU,IAAI,CAAC,IAAmB;QAC5C,IAAI,CAAC;YACH,MAAM,GAAG,GAAG,MAAM,IAAA,qBAAK,EAAC,oBAAoB,CAAC,CAAC;YAC9C,IAAI,GAAG,CAAC,EAAE,EAAE,CAAC;gBACX,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;YAC/B,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC;QAC7B,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,MAAM,EAAE,CAAC;YACT,MAAM,CAAC,CAAC;QACV,CAAC;IACH,CAAC,CAAC;AACJ,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,gCAAgC,EAAE,KAAK,IAAI,EAAE;QAC9C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAErD,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEhF,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAE3G,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAA,cAAI,EAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,IAAA,eAAS,EAAC,IAAI,CAAC,CAAC;QACpC,IAAI,CAAC;YACH,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACzC,CAAC;QAAC,WAAM,CAAC;YACP,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QAC1C,CAAC;IACH,CAAC,EAAE,IAAI,CAAC,CAAC;AACX,CAAC,CAAC,CAAC"}

dist/cjs/throttle.js

@@ -6,2 +6,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.default = makeThrottle;
 const queue_1 = __importDefault(require("./queue"));
@@ -61,3 +62,2 @@ /**
 }
-exports.default = makeThrottle;
 //# sourceMappingURL=throttle.js.map

dist/cjs/throttle.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttle.js","sourceRoot":"","sources":["../../src/throttle.ts"],"names":[],"mappings":";;;;;AAAA,oDAA4B;AAG5B;;;GAGG;AACH,SAAwB,YAAY,CAAoC,GAAW;IACjF,0BAA0B;IAC1B,IAAI,OAAO,GAAG,CAAC,CAAC;IAEhB,sBAAsB;IACtB,MAAM,KAAK,GAAG,IAAI,eAAK,EAAuB,CAAC;IAE/C;;;OAGG;IACH,SAAS,QAAQ,CAAC,EAAK;QACrB,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBACnD;;mBAEG;gBACH,KAAK,UAAU,OAAO;oBACpB,kDAAkD;oBAClD,IAAI,OAAO,GAAG,GAAG,EAAE;wBACjB,oCAAoC;wBACpC,OAAO,EAAE,CAAC;wBAEV,IAAI;4BACF,4DAA4D;4BAC5D,oEAAoE;4BACpE,OAAO,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC,CAAC;yBAC5B;wBAAC,OAAO,CAAC,EAAE;4BACV,MAAM,CAAC,CAAC,CAAC,CAAC;yBACX;wBAED,6DAA6D;wBAC7D,OAAO,EAAE,CAAC;wBAEV,4DAA4D;wBAC5D,UAAU;wBACV,IAAI,KAAK,CAAC,MAAM,GAAG,CAAC,EAAE;4BACpB,KAAK,CAAC,KAAK,EAAG,EAAE,CAAC;yBAClB;qBACF;yBAAM;wBACL,4DAA4D;wBAC5D,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;qBACrB;gBACH,CAAC;gBAED,2BAA2B;gBAC3B,OAAO,OAAO,EAAE,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;IACJ,CAAC;IAED,+BAA+B;IAC/B,OAAO,QAAQ,CAAC;AAClB,CAAC;AArDD,+BAqDC"}
+{"version":3,"file":"throttle.js","sourceRoot":"","sources":["../../src/throttle.ts"],"names":[],"mappings":";;;;;AAOA,+BAqDC;AA5DD,oDAA4B;AAG5B;;;GAGG;AACH,SAAwB,YAAY,CAAoC,GAAW;IACjF,0BAA0B;IAC1B,IAAI,OAAO,GAAG,CAAC,CAAC;IAEhB,sBAAsB;IACtB,MAAM,KAAK,GAAG,IAAI,eAAK,EAAuB,CAAC;IAE/C;;;OAGG;IACH,SAAS,QAAQ,CAAC,EAAK;QACrB,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBACnD;;mBAEG;gBACH,KAAK,UAAU,OAAO;oBACpB,kDAAkD;oBAClD,IAAI,OAAO,GAAG,GAAG,EAAE,CAAC;wBAClB,oCAAoC;wBACpC,OAAO,EAAE,CAAC;wBAEV,IAAI,CAAC;4BACH,4DAA4D;4BAC5D,oEAAoE;4BACpE,OAAO,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC,CAAC;wBAC7B,CAAC;wBAAC,OAAO,CAAC,EAAE,CAAC;4BACX,MAAM,CAAC,CAAC,CAAC,CAAC;wBACZ,CAAC;wBAED,6DAA6D;wBAC7D,OAAO,EAAE,CAAC;wBAEV,4DAA4D;wBAC5D,UAAU;wBACV,IAAI,KAAK,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;4BACrB,KAAK,CAAC,KAAK,EAAG,EAAE,CAAC;wBACnB,CAAC;oBACH,CAAC;yBAAM,CAAC;wBACN,4DAA4D;wBAC5D,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;oBACtB,CAAC;gBACH,CAAC;gBAED,2BAA2B;gBAC3B,OAAO,OAAO,EAAE,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;IACJ,CAAC;IAED,+BAA+B;IAC/B,OAAO,QAAQ,CAAC;AAClB,CAAC"}

dist/cjs/throttle.test.js

@@ -16,3 +16,3 @@ "use strict";
         // Create the pipeline function to use the throttle
-        const pipeline = throttle(async (log) => new Promise(resolve => {
+        const pipeline = throttle(async (log) => new Promise((resolve) => {
             setTimeout(() => {
@@ -35,3 +35,4 @@ resolve(log);
         const expectedTime = (numberOfPromises / max) * throttleTime;
-        expect(end).toBeGreaterThanOrEqual(expectedTime);
+        const toleranceMilliseconds = 0.2;
+        expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
     });
@@ -38,0 +39,0 @@ it("should handle rejections", async () => {

dist/cjs/throttle.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttle.test.js","sourceRoot":"","sources":["../../src/throttle.test.ts"],"names":[],"mappings":";;;;;AAAA,0DAAsC;AAUtC,QAAQ,CAAC,gBAAgB,EAAE,GAAG,EAAE;IAC9B,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,GAAG,GAAG,CAAC,CAAC;QACd,MAAM,YAAY,GAAG,EAAE,CAAC,CAAC,KAAK;QAC9B,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAW,GAAG,CAAC,CAAC;QAE7C,mDAAmD;QACnD,MAAM,QAAQ,GAAG,QAAQ,CACvB,KAAK,EAAC,GAAG,EAAC,EAAE,CACV,IAAI,OAAO,CAAO,OAAO,CAAC,EAAE;YAC1B,UAAU,CAAC,GAAG,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,CAAC;YACf,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CACL,CAAC;QAEF,qBAAqB;QACrB,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE;YACzC,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;SAC7C;QAED,mCAAmC;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC;QAE/C,oEAAoE;QACpE,MAAM,YAAY,GAAG,CAAC,gBAAgB,GAAG,GAAG,CAAC,GAAG,YAAY,CAAC;QAE7D,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,CAAC,CAAC;IACnD,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAC,CAAC,CAAC,CAAC;QAEjC,gBAAgB;QAChB,IAAI,MAAM,GAAG,CAAC,CAAC;QAEf,4DAA4D;QAC5D,MAAM,QAAQ,GAAG,QAAQ,CAAC,KAAK,EAAC,CAAC,EAAC,EAAE;YAClC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE;gBACd,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;aACtD;YACD,OAAO,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE;YACzC,MAAM,QAAQ,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC;SACzC;QAED,MAAM,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,gBAAgB,GAAG,CAAC,CAAC,CAAC;IAC/C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"throttle.test.js","sourceRoot":"","sources":["../../src/throttle.test.ts"],"names":[],"mappings":";;;;;AAAA,0DAAsC;AAUtC,QAAQ,CAAC,gBAAgB,EAAE,GAAG,EAAE;IAC9B,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,GAAG,GAAG,CAAC,CAAC;QACd,MAAM,YAAY,GAAG,EAAE,CAAC,CAAC,KAAK;QAC9B,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAW,GAAG,CAAC,CAAC;QAE7C,mDAAmD;QACnD,MAAM,QAAQ,GAAG,QAAQ,CACvB,KAAK,EAAE,GAAG,EAAE,EAAE,CACZ,IAAI,OAAO,CAAO,CAAC,OAAO,EAAE,EAAE;YAC5B,UAAU,CAAC,GAAG,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,CAAC;YACf,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CACL,CAAC;QAEF,qBAAqB;QACrB,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE,CAAC;YAC1C,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;QAC9C,CAAC;QAED,mCAAmC;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC;QAE/C,oEAAoE;QACpE,MAAM,YAAY,GAAG,CAAC,gBAAgB,GAAG,GAAG,CAAC,GAAG,YAAY,CAAC;QAC7D,MAAM,qBAAqB,GAAG,GAAG,CAAC;QAElC,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,GAAG,qBAAqB,CAAC,CAAC;IAC3E,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,IAAA,kBAAY,EAAC,CAAC,CAAC,CAAC;QAEjC,gBAAgB;QAChB,IAAI,MAAM,GAAG,CAAC,CAAC;QAEf,4DAA4D;QAC5D,MAAM,QAAQ,GAAG,QAAQ,CAAC,KAAK,EAAE,CAAC,EAAE,EAAE;YACpC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;gBACf,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;YACvD,CAAC;YACD,OAAO,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE,CAAC;YAC1C,MAAM,QAAQ,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC;QAC1C,CAAC;QAED,MAAM,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,gBAAgB,GAAG,CAAC,CAAC,CAAC;IAC/C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

dist/es6/batch.js

@@ -52,4 +52,4 @@ /*
         try {
-            await cb(currentBuffer.map(d => d.log));
-            currentBuffer.forEach(d => d.resolve(d.log));
+            await cb(currentBuffer.map((d) => d.log));
+            currentBuffer.forEach((d) => d.resolve(d.log));
             retry = 0;
@@ -66,3 +66,3 @@ }
             }
-            currentBuffer.map(d => d.reject(e));
+            currentBuffer.map((d) => d.reject(e));
             retry = 0;
@@ -78,3 +78,3 @@ }
         }
-        return new Promise(resolve => {
+        return new Promise((resolve) => {
             timeout = setTimeout(async function () {
@@ -81,0 +81,0 @@ await flush();

dist/es6/batch.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"batch.js","sourceRoot":"","sources":["../../src/batch.ts"],"names":[],"mappings":"AAaA;;GAEG;AACH,MAAM,mBAAmB,GAAG,IAAI,CAAC;AAEjC;;GAEG;AACH,MAAM,qBAAqB,GAAG,IAAI,CAAC;AAEnC;;GAEG;AACH,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAE9B;;GAEG;AACH,MAAM,qBAAqB,GAAG,GAAG,CAAC;AAElC;;GAEG;AACH,MAAM,CAAC,MAAM,yBAAyB,GAAG,CAAC,GAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;AAE9F;;;;;;;;;GASG;AACH,MAAM,CAAC,OAAO,UAAU,SAAS,CAC/B,OAAe,mBAAmB,EAClC,eAAuB,qBAAqB,EAC5C,aAAqB,mBAAmB,EACxC,eAAuB,qBAAqB,EAC5C,YAAoB,CAAC,EACrB,wBAAsD,yBAAyB;IAE/E,IAAI,OAA8B,CAAC;IACnC,IAAI,EAAY,CAAC;IACjB,IAAI,MAAM,GAAc,EAAE,CAAC;IAC3B,IAAI,eAAe,GAAG,CAAC,CAAC;IACxB,IAAI,KAAK,GAAW,CAAC,CAAC;IACtB,uEAAuE;IACvE,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC;;OAEG;IACH,KAAK,UAAU,KAAK;QAClB,IAAI,OAAO,EAAE;YACX,YAAY,CAAC,OAAO,CAAC,CAAC;SACvB;QACD,OAAO,GAAG,IAAI,CAAC;QAEf,MAAM,aAAa,GAAG,MAAM,CAAC;QAC7B,MAAM,mBAAmB,GAAG,eAAe,CAAC;QAC5C,MAAM,GAAG,EAAE,CAAC;QACZ,eAAe,GAAG,CAAC,CAAC;QAEpB,IAAI;YACF,MAAM,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACxC,aAAa,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC7C,KAAK,GAAG,CAAC,CAAC;SACX;QAAC,OAAO,CAAC,EAAE;YACV,IAAI,KAAK,GAAG,UAAU,EAAE;gBACtB,KAAK,EAAE,CAAC;gBACR,eAAe,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAC;gBAC5C,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,aAAa,CAAC,CAAC;gBACtC,eAAe,IAAI,mBAAmB,CAAC;gBACvC,MAAM,YAAY,EAAE,CAAC;gBACrB,OAAO;aACR;YACD,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;YACpC,KAAK,GAAG,CAAC,CAAC;SACX;IACH,CAAC;IAED;;OAEG;IACH,KAAK,UAAU,YAAY;QACzB,IAAI,OAAO,EAAE;YACX,OAAO;SACR;QAED,OAAO,IAAI,OAAO,CAAO,OAAO,CAAC,EAAE;YACjC,OAAO,GAAG,UAAU,CAAC,KAAK;gBACxB,MAAM,KAAK,EAAE,CAAC;gBACd,OAAO,EAAE,CAAC;YACZ,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,OAAO;QACL,UAAU,EAAE,UAAS,EAAY;YAC/B,EAAE,GAAG,EAAE,CAAC;YAER;;;eAGG;YACH,OAAO,KAAK,WAAU,GAAgB;gBACpC,OAAO,IAAI,OAAO,CAAc,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxD,MAAM,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,MAAM,EAAE,CAAC,CAAC;oBACtC,+DAA+D;oBAC/D,IAAI,SAAS,GAAG,CAAC,EAAE;wBACjB,eAAe,IAAI,qBAAqB,CAAC,GAAG,CAAC,CAAC;qBAC/C;oBAED,yCAAyC;oBACzC,gEAAgE;oBAChE,MAAM,kBAAkB,GAAG,MAAM,CAAC,MAAM,IAAI,IAAI,IAAI,CAAC,SAAS,GAAG,CAAC,IAAI,eAAe,IAAI,SAAS,CAAC,CAAC;oBACpG,IAAI,kBAAkB,IAAI,IAAI,CAAC,GAAG,EAAE,GAAG,eAAe,EAAE;wBACtD,MAAM,KAAK,EAAE,CAAC;qBACf;yBAAM;wBACL,MAAM,YAAY,EAAE,CAAC;qBACtB;oBAED,OAAO,OAAO,CAAC;gBACjB,CAAC,CAAC,CAAC;YACL,CAAC,CAAC;QACJ,CAAC;QACD,KAAK;KACN,CAAC;AACJ,CAAC"}
+{"version":3,"file":"batch.js","sourceRoot":"","sources":["../../src/batch.ts"],"names":[],"mappings":"AAaA;;GAEG;AACH,MAAM,mBAAmB,GAAG,IAAI,CAAC;AAEjC;;GAEG;AACH,MAAM,qBAAqB,GAAG,IAAI,CAAC;AAEnC;;GAEG;AACH,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAE9B;;GAEG;AACH,MAAM,qBAAqB,GAAG,GAAG,CAAC;AAElC;;GAEG;AACH,MAAM,CAAC,MAAM,yBAAyB,GAAG,CAAC,GAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;AAE9F;;;;;;;;;GASG;AACH,MAAM,CAAC,OAAO,UAAU,SAAS,CAC/B,OAAe,mBAAmB,EAClC,eAAuB,qBAAqB,EAC5C,aAAqB,mBAAmB,EACxC,eAAuB,qBAAqB,EAC5C,YAAoB,CAAC,EACrB,wBAAsD,yBAAyB;IAE/E,IAAI,OAA8B,CAAC;IACnC,IAAI,EAAY,CAAC;IACjB,IAAI,MAAM,GAAc,EAAE,CAAC;IAC3B,IAAI,eAAe,GAAG,CAAC,CAAC;IACxB,IAAI,KAAK,GAAW,CAAC,CAAC;IACtB,uEAAuE;IACvE,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC;;OAEG;IACH,KAAK,UAAU,KAAK;QAClB,IAAI,OAAO,EAAE,CAAC;YACZ,YAAY,CAAC,OAAO,CAAC,CAAC;QACxB,CAAC;QACD,OAAO,GAAG,IAAI,CAAC;QAEf,MAAM,aAAa,GAAG,MAAM,CAAC;QAC7B,MAAM,mBAAmB,GAAG,eAAe,CAAC;QAC5C,MAAM,GAAG,EAAE,CAAC;QACZ,eAAe,GAAG,CAAC,CAAC;QAEpB,IAAI,CAAC;YACH,MAAM,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC1C,aAAa,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YAC/C,KAAK,GAAG,CAAC,CAAC;QACZ,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,IAAI,KAAK,GAAG,UAAU,EAAE,CAAC;gBACvB,KAAK,EAAE,CAAC;gBACR,eAAe,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAC;gBAC5C,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,aAAa,CAAC,CAAC;gBACtC,eAAe,IAAI,mBAAmB,CAAC;gBACvC,MAAM,YAAY,EAAE,CAAC;gBACrB,OAAO;YACT,CAAC;YACD,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;YACtC,KAAK,GAAG,CAAC,CAAC;QACZ,CAAC;IACH,CAAC;IAED;;OAEG;IACH,KAAK,UAAU,YAAY;QACzB,IAAI,OAAO,EAAE,CAAC;YACZ,OAAO;QACT,CAAC;QAED,OAAO,IAAI,OAAO,CAAO,CAAC,OAAO,EAAE,EAAE;YACnC,OAAO,GAAG,UAAU,CAAC,KAAK;gBACxB,MAAM,KAAK,EAAE,CAAC;gBACd,OAAO,EAAE,CAAC;YACZ,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,OAAO;QACL,UAAU,EAAE,UAAU,EAAY;YAChC,EAAE,GAAG,EAAE,CAAC;YAER;;;eAGG;YACH,OAAO,KAAK,WAAW,GAAgB;gBACrC,OAAO,IAAI,OAAO,CAAc,KAAK,EAAE,OAAO,EAAE,MAAM,EAAE,EAAE;oBACxD,MAAM,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,MAAM,EAAE,CAAC,CAAC;oBACtC,+DAA+D;oBAC/D,IAAI,SAAS,GAAG,CAAC,EAAE,CAAC;wBAClB,eAAe,IAAI,qBAAqB,CAAC,GAAG,CAAC,CAAC;oBAChD,CAAC;oBAED,yCAAyC;oBACzC,gEAAgE;oBAChE,MAAM,kBAAkB,GAAG,MAAM,CAAC,MAAM,IAAI,IAAI,IAAI,CAAC,SAAS,GAAG,CAAC,IAAI,eAAe,IAAI,SAAS,CAAC,CAAC;oBACpG,IAAI,kBAAkB,IAAI,IAAI,CAAC,GAAG,EAAE,GAAG,eAAe,EAAE,CAAC;wBACvD,MAAM,KAAK,EAAE,CAAC;oBAChB,CAAC;yBAAM,CAAC;wBACN,MAAM,YAAY,EAAE,CAAC;oBACvB,CAAC;oBAED,OAAO,OAAO,CAAC;gBACjB,CAAC,CAAC,CAAC;YACL,CAAC,CAAC;QACJ,CAAC;QACD,KAAK;KACN,CAAC;AACJ,CAAC"}

dist/es6/batch.test.js

@@ -44,3 +44,3 @@ import nock from "nock";
             .get("/")
-            .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+            .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
         const called = jest.fn();
@@ -59,3 +59,3 @@ const size = 5;
         });
-        await Promise.all(logNumberTimes(logger, 5)).catch(e => {
+        await Promise.all(logNumberTimes(logger, 5)).catch((e) => {
             throw e;
@@ -77,3 +77,3 @@ });
         });
-        await Promise.all(logNumberTimes(logger, 5)).catch(e => { });
+        await Promise.all(logNumberTimes(logger, 5)).catch((e) => { });
         expect(called).toHaveBeenCalledTimes(4); // 3 retries + 1 initial
@@ -93,3 +93,3 @@ });
         });
-        logger(getRandomLog()).catch(e => { });
+        logger(getRandomLog()).catch((e) => { });
         await batcher.flush();
@@ -108,3 +108,3 @@ expect(called).toHaveBeenCalledTimes(4); // 3 retries + 1 initial
         const throttler = throttle(async (logs) => {
-            return new Promise(resolve => {
+            return new Promise((resolve) => {
                 setTimeout(() => resolve(logs), throttleResolveAfter);
@@ -134,3 +134,4 @@ });
         const expectedTime = ((numberOfLogs / batchSize) * throttleResolveAfter) / maxThrottle;
-        expect(end).toBeGreaterThanOrEqual(expectedTime);
+        const toleranceMilliseconds = 0.2;
+        expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
     });
@@ -140,3 +141,3 @@ it("should send after flush (with long timeout)", async () => {
             .get("/")
-            .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+            .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
         const called = jest.fn();
@@ -179,3 +180,3 @@ const size = 50;
         // 100 logs with 50B each is 5000B in total - expecting 10 batches of 500B
-        await Promise.all(logNumberTimes(logger, 100)).catch(e => {
+        await Promise.all(logNumberTimes(logger, 100)).catch((e) => {
             throw e;
@@ -182,0 +183,0 @@ });

dist/es6/batch.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"batch.test.js","sourceRoot":"","sources":["../../src/batch.test.ts"],"names":[],"mappings":"AAAA,OAAO,IAAI,MAAM,MAAM,CAAC;AACxB,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,EAAe,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACvD,OAAO,SAAS,EAAE,EAAE,yBAAyB,EAAE,MAAM,SAAS,CAAC;AAC/D,OAAO,YAAY,MAAM,YAAY,CAAC;AAEtC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,QAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED;;;;;GAKG;AACH,SAAS,cAAc,CAAC,MAAgB,EAAE,CAAS;IACjD,OAAO,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;AAChE,CAAC;AAED;;;GAGG;AACH,SAAS,WAAW,CAAC,KAAuB;IAC1C,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAClC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,GAAG,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC;AACvC,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,UAAU,CAAC,GAAG,EAAE;QACd,IAAI,CAAC,OAAO,EAAE,CAAC;QACf,IAAI,CAAC,QAAQ,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;IACH,SAAS,CAAC,GAAG,EAAE;QACb,IAAI,CAAC,OAAO,EAAE,CAAC;IACjB,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,qDAAqD,EAAE,KAAK,IAAI,EAAE;QACnE,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEpE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QAEvB,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI;gBACF,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;aACnC;YAAC,OAAO,CAAC,EAAE;gBACV,MAAM,CAAC,CAAC;aACT;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE;YACrD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,uBAAuB,EAAE,KAAK,IAAI,EAAE;QACrC,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,GAAE,CAAC,CAAC,CAAC;QAC5D,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,GAAE,CAAC,CAAC,CAAC;QACtC,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,oCAAoC,EAAE,KAAK,IAAI,EAAE;QAClD,WAAW;QACX,MAAM,WAAW,GAAG,CAAC,CAAC;QACtB,MAAM,oBAAoB,GAAG,IAAI,CAAC,CAAC,KAAK;QACxC,MAAM,SAAS,GAAG,CAAC,CAAC;QACpB,MAAM,YAAY,GAAG,EAAE,CAAC;QAExB,sDAAsD;QACtD,MAAM,QAAQ,GAAG,YAAY,CAAC,WAAW,CAAC,CAAC;QAE3C,uCAAuC;QACvC,MAAM,SAAS,GAAG,QAAQ,CAAC,KAAK,EAAC,IAAI,EAAC,EAAE;YACtC,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE;gBAC3B,UAAU,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,oBAAoB,CAAC,CAAC;YACxD,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;QAEH,2CAA2C;QAC3C,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,uDAAuD;QACvD,MAAM,KAAK,GAAG,SAAS,CAAC,SAAS,EAAE,IAAI,CAAC,CAAC;QAEzC,kCAAkC;QAClC,MAAM,OAAO,GAAG,KAAK,CAAC,UAAU,CAAC,CAAC,IAAS,EAAE,EAAE;YAC7C,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;YACvC,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACzB,CAAC,CAAC,CAAC;QAEH,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,4CAA4C;QAC5C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,YAAY,EAAE,CAAC,EAAE,EAAE;YACrC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;SACxC;QAED,gCAAgC;QAChC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,qDAAqD;QACrD,MAAM,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,CAAC;QAE/B,kDAAkD;QAClD,MAAM,YAAY,GAAG,CAAC,CAAC,YAAY,GAAG,SAAS,CAAC,GAAG,oBAAoB,CAAC,GAAG,WAAW,CAAC;QAEvF,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,CAAC,CAAC;IACnD,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6CAA6C,EAAE,KAAK,IAAI,EAAE;QAC3D,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEpE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAChB,MAAM,WAAW,GAAG,KAAK,CAAC;QAE1B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI;gBACF,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;aACnC;YAAC,OAAO,CAAC,EAAE;gBACV,MAAM,CAAC,CAAC;aACT;QACH,CAAC,CAAC,CAAC;QAEH,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QAC1B,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QACxC,IAAI;YACF,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;SACvB;QAAC,OAAO,CAAC,EAAE;YACV,MAAM,CAAC,CAAC;SACT;QACD,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,4CAA4C,EAAE,KAAK,IAAI,EAAE;QAC1D,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,MAAM,WAAW,GAAG,IAAI,CAAC;QACzB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QAEvB,6DAA6D;QAC7D,MAAM,SAAS,GAAG,GAAG,CAAC;QACtB,MAAM,aAAa,GAAG,CAAC,IAAiB,EAAE,EAAE,CAAC,EAAE,CAAC;QAEhD,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QACjG,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,MAAqB,EAAE,EAAE;YAChE,MAAM,EAAE,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,0EAA0E;QAC1E,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE;YACvD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEH,QAAQ,CAAC,0BAA0B,EAAE,GAAG,EAAE;IACxC,EAAE,CAAC,0CAA0C,EAAE,KAAK,IAAI,EAAE;QACxD,MAAM,GAAG,GAAgB;YACvB,EAAE,EAAE,IAAI,IAAI,EAAE;YACd,KAAK,EAAE,QAAQ,CAAC,IAAI;YACpB,OAAO,EAAE,YAAY;SACtB,CAAC;QAEF,MAAM,kBAAkB,GAAG,yBAAyB,CAAC,GAAG,CAAC,CAAC;QAC1D,MAAM,oBAAoB,GAAG,0EAA0E,CAAC,MAAM,CAAC;QAE/G,MAAM,CAAC,kBAAkB,CAAC,CAAC,OAAO,CAAC,oBAAoB,CAAC,CAAC;IAC3D,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"batch.test.js","sourceRoot":"","sources":["../../src/batch.test.ts"],"names":[],"mappings":"AAAA,OAAO,IAAI,MAAM,MAAM,CAAC;AACxB,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,EAAe,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACvD,OAAO,SAAS,EAAE,EAAE,yBAAyB,EAAE,MAAM,SAAS,CAAC;AAC/D,OAAO,YAAY,MAAM,YAAY,CAAC;AAEtC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,QAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED;;;;;GAKG;AACH,SAAS,cAAc,CAAC,MAAgB,EAAE,CAAS;IACjD,OAAO,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;AAChE,CAAC;AAED;;;GAGG;AACH,SAAS,WAAW,CAAC,KAAuB;IAC1C,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAClC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,GAAG,GAAG,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,GAAG,CAAC;AACvC,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,UAAU,CAAC,GAAG,EAAE;QACd,IAAI,CAAC,OAAO,EAAE,CAAC;QACf,IAAI,CAAC,QAAQ,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;IACH,SAAS,CAAC,GAAG,EAAE;QACb,IAAI,CAAC,OAAO,EAAE,CAAC;IACjB,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,qDAAqD,EAAE,KAAK,IAAI,EAAE;QACnE,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEtE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QAEvB,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI,CAAC;gBACH,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;YACpC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,MAAM,CAAC,CAAC;YACV,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE;YACvD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,uBAAuB,EAAE,KAAK,IAAI,EAAE;QACrC,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE,GAAE,CAAC,CAAC,CAAC;QAC9D,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,CAAC,CAAC;QACf,MAAM,WAAW,GAAG,EAAE,CAAC;QACvB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QACvB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,MAAM,CAAC,CAAC;QAE9B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,CAAC,CAAC;QACvE,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,MAAM,GAAG,CAAC;QACZ,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,YAAY,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE,GAAE,CAAC,CAAC,CAAC;QACxC,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC,CAAC,wBAAwB;IACnE,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,oCAAoC,EAAE,KAAK,IAAI,EAAE;QAClD,WAAW;QACX,MAAM,WAAW,GAAG,CAAC,CAAC;QACtB,MAAM,oBAAoB,GAAG,IAAI,CAAC,CAAC,KAAK;QACxC,MAAM,SAAS,GAAG,CAAC,CAAC;QACpB,MAAM,YAAY,GAAG,EAAE,CAAC;QAExB,sDAAsD;QACtD,MAAM,QAAQ,GAAG,YAAY,CAAC,WAAW,CAAC,CAAC;QAE3C,uCAAuC;QACvC,MAAM,SAAS,GAAG,QAAQ,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE;YACxC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE;gBAC7B,UAAU,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,oBAAoB,CAAC,CAAC;YACxD,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;QAEH,2CAA2C;QAC3C,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,uDAAuD;QACvD,MAAM,KAAK,GAAG,SAAS,CAAC,SAAS,EAAE,IAAI,CAAC,CAAC;QAEzC,kCAAkC;QAClC,MAAM,OAAO,GAAG,KAAK,CAAC,UAAU,CAAC,CAAC,IAAS,EAAE,EAAE;YAC7C,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;YACvC,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACzB,CAAC,CAAC,CAAC;QAEH,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,4CAA4C;QAC5C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,YAAY,EAAE,CAAC,EAAE,EAAE,CAAC;YACtC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,YAAY,EAAE,CAAC,CAAC,CAAC;QACzC,CAAC;QAED,gCAAgC;QAChC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,qDAAqD;QACrD,MAAM,GAAG,GAAG,WAAW,CAAC,KAAK,CAAC,CAAC;QAE/B,kDAAkD;QAClD,MAAM,YAAY,GAAG,CAAC,CAAC,YAAY,GAAG,SAAS,CAAC,GAAG,oBAAoB,CAAC,GAAG,WAAW,CAAC;QACvF,MAAM,qBAAqB,GAAG,GAAG,CAAC;QAElC,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,GAAG,qBAAqB,CAAC,CAAC;IAC3E,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6CAA6C,EAAE,KAAK,IAAI,EAAE;QAC3D,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,OAAO,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,UAAU,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC,CAAC,CAAC;QAEtE,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAChB,MAAM,WAAW,GAAG,KAAK,CAAC;QAE1B,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,KAAoB,EAAE,EAAE;YAC/D,MAAM,EAAE,CAAC;YACT,IAAI,CAAC;gBACH,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;YACpC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,MAAM,CAAC,CAAC;YACV,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,cAAc,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC;QAC1B,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QACxC,IAAI,CAAC;YACH,MAAM,OAAO,CAAC,KAAK,EAAE,CAAC;QACxB,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,MAAM,CAAC,CAAC;QACV,CAAC;QACD,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,4CAA4C,EAAE,KAAK,IAAI,EAAE;QAC1D,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,IAAI,CAAC;QAClB,MAAM,WAAW,GAAG,IAAI,CAAC;QACzB,MAAM,UAAU,GAAG,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,CAAC,CAAC;QAEvB,6DAA6D;QAC7D,MAAM,SAAS,GAAG,GAAG,CAAC;QACtB,MAAM,aAAa,GAAG,CAAC,IAAiB,EAAE,EAAE,CAAC,EAAE,CAAC;QAEhD,MAAM,OAAO,GAAG,SAAS,CAAC,IAAI,EAAE,WAAW,EAAE,UAAU,EAAE,YAAY,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QACjG,MAAM,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC,KAAK,EAAE,MAAqB,EAAE,EAAE;YAChE,MAAM,EAAE,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,0EAA0E;QAC1E,MAAM,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,EAAE;YACzD,MAAM,CAAC,CAAC;QACV,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEH,QAAQ,CAAC,0BAA0B,EAAE,GAAG,EAAE;IACxC,EAAE,CAAC,0CAA0C,EAAE,KAAK,IAAI,EAAE;QACxD,MAAM,GAAG,GAAgB;YACvB,EAAE,EAAE,IAAI,IAAI,EAAE;YACd,KAAK,EAAE,QAAQ,CAAC,IAAI;YACpB,OAAO,EAAE,YAAY;SACtB,CAAC;QAEF,MAAM,kBAAkB,GAAG,yBAAyB,CAAC,GAAG,CAAC,CAAC;QAC1D,MAAM,oBAAoB,GAAG,0EAA0E,CAAC,MAAM,CAAC;QAE/G,MAAM,CAAC,kBAAkB,CAAC,CAAC,OAAO,CAAC,oBAAoB,CAAC,CAAC;IAC3D,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

dist/es6/burstProtection.js

@@ -23,6 +23,3 @@ const RESOLUTION = 64;
         const intervalCountSinceLast = Math.floor((now - lastIntervalTime) / intervalLength);
-        callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION))
-            .fill(0)
-            .concat(callCounts)
-            .slice(0, RESOLUTION);
+        callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION)).fill(0).concat(callCounts).slice(0, RESOLUTION);
         lastIntervalTime += intervalCountSinceLast * intervalLength;
@@ -29,0 +26,0 @@ }

dist/es6/burstProtection.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"burstProtection.js","sourceRoot":"","sources":["../../src/burstProtection.ts"],"names":[],"mappings":"AAEA,MAAM,UAAU,GAAG,EAAE,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,CAAC,OAAO,UAAU,mBAAmB,CACzC,YAAoB,EACpB,GAAW,EACX,eAAuB,cAAc;IAErC,IAAI,YAAY,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,EAAE;QACjC,OAAO,CAAC,EAAK,EAAE,EAAE,CAAC,EAAE,CAAC;KACtB;IAED,IAAI,UAAU,GAAa,CAAC,CAAC,CAAC,CAAC;IAC/B,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC,IAAI,gBAAgB,GAAW,IAAI,CAAC,GAAG,EAAE,CAAC;IAE1C,SAAS,gBAAgB;QACvB,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;QACvB,MAAM,cAAc,GAAG,YAAY,GAAG,UAAU,CAAC;QAEjD,IAAI,GAAG,GAAG,gBAAgB,GAAG,cAAc,EAAE;YAC3C,OAAO;SACR;QAED,4FAA4F;QAC5F,MAAM,sBAAsB,GAAG,IAAI,CAAC,KAAK,CAAC,CAAC,GAAG,GAAG,gBAAgB,CAAC,GAAG,cAAc,CAAC,CAAC;QACrF,UAAU,GAAG,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,sBAAsB,EAAE,UAAU,CAAC,CAAC;aAC7D,IAAI,CAAC,CAAC,CAAC;aACP,MAAM,CAAC,UAAU,CAAC;aAClB,KAAK,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;QACxB,gBAAgB,IAAI,sBAAsB,GAAG,cAAc,CAAC;IAC9D,CAAC;IAED,SAAS,iBAAiB;QACxB,OAAO,UAAU,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;IAC1D,CAAC;IAED,SAAS,kBAAkB;QACzB,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC;IAClB,CAAC;IAED,OAAO,CAAC,EAAK,EAAE,EAAE;QACf,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,gBAAgB,EAAE,CAAC;YACnB,IAAI,iBAAiB,EAAE,GAAG,GAAG,EAAE;gBAC7B,kBAAkB,EAAE,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC;aAC1B;YAED,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACvB,IAAI,eAAe,GAAG,GAAG,GAAG,YAAY,EAAE;gBACxC,eAAe,GAAG,GAAG,CAAC;gBACtB,OAAO,CAAC,KAAK,CAAC,GAAG,YAAY,yBAAyB,GAAG,sBAAsB,YAAY,eAAe,CAAC,CAAC;aAC7G;QACH,CAAC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC"}
+{"version":3,"file":"burstProtection.js","sourceRoot":"","sources":["../../src/burstProtection.ts"],"names":[],"mappings":"AAEA,MAAM,UAAU,GAAG,EAAE,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,CAAC,OAAO,UAAU,mBAAmB,CACzC,YAAoB,EACpB,GAAW,EACX,eAAuB,cAAc;IAErC,IAAI,YAAY,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,EAAE,CAAC;QAClC,OAAO,CAAC,EAAK,EAAE,EAAE,CAAC,EAAE,CAAC;IACvB,CAAC;IAED,IAAI,UAAU,GAAa,CAAC,CAAC,CAAC,CAAC;IAC/B,IAAI,eAAe,GAAW,CAAC,CAAC;IAChC,IAAI,gBAAgB,GAAW,IAAI,CAAC,GAAG,EAAE,CAAC;IAE1C,SAAS,gBAAgB;QACvB,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;QACvB,MAAM,cAAc,GAAG,YAAY,GAAG,UAAU,CAAC;QAEjD,IAAI,GAAG,GAAG,gBAAgB,GAAG,cAAc,EAAE,CAAC;YAC5C,OAAO;QACT,CAAC;QAED,4FAA4F;QAC5F,MAAM,sBAAsB,GAAG,IAAI,CAAC,KAAK,CAAC,CAAC,GAAG,GAAG,gBAAgB,CAAC,GAAG,cAAc,CAAC,CAAC;QACrF,UAAU,GAAG,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,sBAAsB,EAAE,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;QACjH,gBAAgB,IAAI,sBAAsB,GAAG,cAAc,CAAC;IAC9D,CAAC;IAED,SAAS,iBAAiB;QACxB,OAAO,UAAU,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;IAC1D,CAAC;IAED,SAAS,kBAAkB;QACzB,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC;IAClB,CAAC;IAED,OAAO,CAAC,EAAK,EAAE,EAAE;QACf,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,gBAAgB,EAAE,CAAC;YACnB,IAAI,iBAAiB,EAAE,GAAG,GAAG,EAAE,CAAC;gBAC9B,kBAAkB,EAAE,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC;YAC3B,CAAC;YAED,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACvB,IAAI,eAAe,GAAG,GAAG,GAAG,YAAY,EAAE,CAAC;gBACzC,eAAe,GAAG,GAAG,CAAC;gBACtB,OAAO,CAAC,KAAK,CAAC,GAAG,YAAY,yBAAyB,GAAG,sBAAsB,YAAY,eAAe,CAAC,CAAC;YAC9G,CAAC;QACH,CAAC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC"}

dist/es6/queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queue.js","sourceRoot":"","sources":["../../src/queue.ts"],"names":[],"mappings":"AAEA;;;GAGG;AACH,MAAM,CAAC,OAAO,OAAO,KAAK;IAA1B;QACE;;WAEG;QAQH;;WAEG;QACI,WAAM,GAAG,CAAC,CAAC;IAyBpB,CAAC;IAvBC;;;OAGG;IACI,IAAI,CAAC,KAAU;QACpB,MAAM,IAAI,GAAG,EAAE,KAAK,EAAE,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;QACtE,IAAI,CAAC,MAAM,EAAE,CAAC;IAChB,CAAC;IAED;;OAEG;IACI,KAAK;QACV,IAAI,IAAI,CAAC,KAAK,EAAE;YACd,MAAM,EAAE,KAAK,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC;YAC7B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YAC7B,IAAI,CAAC,EAAE,IAAI,CAAC,MAAM,EAAE;gBAClB,IAAI,CAAC,IAAI,GAAG,SAAS,CAAC;aACvB;YACD,OAAO,KAAK,CAAC;SACd;IACH,CAAC;CACF"}
+{"version":3,"file":"queue.js","sourceRoot":"","sources":["../../src/queue.ts"],"names":[],"mappings":"AAEA;;;GAGG;AACH,MAAM,CAAC,OAAO,OAAO,KAAK;IAA1B;QACE;;WAEG;QAQH;;WAEG;QACI,WAAM,GAAG,CAAC,CAAC;IAyBpB,CAAC;IAvBC;;;OAGG;IACI,IAAI,CAAC,KAAU;QACpB,MAAM,IAAI,GAAG,EAAE,KAAK,EAAE,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,CAAC;QACtE,IAAI,CAAC,MAAM,EAAE,CAAC;IAChB,CAAC;IAED;;OAEG;IACI,KAAK;QACV,IAAI,IAAI,CAAC,KAAK,EAAE,CAAC;YACf,MAAM,EAAE,KAAK,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC;YAC7B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YAC7B,IAAI,CAAC,EAAE,IAAI,CAAC,MAAM,EAAE,CAAC;gBACnB,IAAI,CAAC,IAAI,GAAG,SAAS,CAAC;YACxB,CAAC;YACD,OAAO,KAAK,CAAC;QACf,CAAC;IACH,CAAC;CACF"}

dist/es6/queue.test.js

@@ -22,3 +22,3 @@ import Queue from "./queue";
         // against the values from the queue
-        list.forEach(item => {
+        list.forEach((item) => {
             expect(q.shift()).toEqual(item);
@@ -25,0 +25,0 @@ });

dist/es6/queue.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queue.test.js","sourceRoot":"","sources":["../../src/queue.test.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,SAAS,CAAC;AAE5B,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,+CAA+C,EAAE,GAAG,EAAE;QACvD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QAEzB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,yCAAyC,EAAE,GAAG,EAAE;QACjD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAEhB,2CAA2C;QAC3C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;YACb,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,oDAAoD;QACpD,oCAAoC;QACpC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAClB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAClC,CAAC,CAAC,CAAC;QAEH,4BAA4B;QAC5B,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC9B,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6BAA6B,EAAE,GAAG,EAAE;QACrC,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,MAAM,CAAC;QAE7B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE;YACtC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACX;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,2CAA2C,EAAE,GAAG,EAAE;QACnD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IACvC,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"queue.test.js","sourceRoot":"","sources":["../../src/queue.test.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,SAAS,CAAC;AAE5B,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,+CAA+C,EAAE,GAAG,EAAE;QACvD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QAEzB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,yCAAyC,EAAE,GAAG,EAAE;QACjD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,EAAE,CAAC;QACzB,MAAM,IAAI,GAAG,EAAE,CAAC;QAEhB,2CAA2C;QAC3C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;YACb,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,oDAAoD;QACpD,oCAAoC;QACpC,IAAI,CAAC,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE;YACpB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAClC,CAAC,CAAC,CAAC;QAEH,4BAA4B;QAC5B,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;IAC9B,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,6BAA6B,EAAE,GAAG,EAAE;QACrC,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QACtB,MAAM,aAAa,GAAG,MAAM,CAAC;QAE7B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,aAAa,EAAE,CAAC,EAAE,EAAE,CAAC;YACvC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACZ,CAAC;QAED,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,2CAA2C,EAAE,GAAG,EAAE;QACnD,MAAM,CAAC,GAAG,IAAI,KAAK,EAAE,CAAC;QAEtB,MAAM,CAAC,CAAC,CAAC,KAAK,EAAE,CAAC,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IACvC,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

dist/es6/retry.js

@@ -11,3 +11,3 @@ /**
 function delay(sec) {
-    return new Promise(resolve => setTimeout(resolve, sec * 1000));
+    return new Promise((resolve) => setTimeout(resolve, sec * 1000));
 }
@@ -14,0 +14,0 @@ /**

dist/es6/retry.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"retry.js","sourceRoot":"","sources":["../../src/retry.ts"],"names":[],"mappings":"AAEA;;GAEG;AACH,IAAI,SAAS,GAAG,CAAC,CAAC;AAElB;;;;GAIG;AACH,SAAS,KAAK,CAAC,GAAW;IACxB,OAAO,IAAI,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,UAAU,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI,CAAC,CAAC,CAAC;AACjE,CAAC;AAED;;;;GAIG;AACH,MAAM,CAAC,OAAO,CAAC,KAAK,UAAU,SAAS,CAAC,EAAmD;IACzF;;OAEG;IACH,IAAI,KAAK,GAAW,CAAC,CAAC;IAEtB;;OAEG;IACH,IAAI,QAAQ,GAAa,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAEhC;;;OAGG;IACH,OAAO,KAAK,UAAU,KAAK,CAAC,IAAmB;QAC7C,8CAA8C;QAC9C,OAAO,KAAK,EAAE,GAAG,SAAS,EAAE;YAC1B,IAAI;gBACF;;mBAEG;gBACH,MAAM,OAAO,GAAG,QAAQ;qBACrB,KAAK,EAAE;qBACP,OAAO,EAAE;qBACT,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC;qBACX,MAAM,CAAC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,CAAC,GAAG,GAAG,IAAI,EAAE,CAAC,CAAC,CAAC;gBAExC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACvB,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,IAAI,CAAC,CAAC;aACvB;YAAC,OAAO,CAAC,EAAE;gBACV;;mBAEG;gBACH,IAAI,KAAK,KAAK,SAAS,EAAE;oBACvB,MAAM,CAAC,CAAC;iBACT;aACF;SACF;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IAC/B,CAAC,CAAC;AACJ,CAAC"}
+{"version":3,"file":"retry.js","sourceRoot":"","sources":["../../src/retry.ts"],"names":[],"mappings":"AAEA;;GAEG;AACH,IAAI,SAAS,GAAG,CAAC,CAAC;AAElB;;;;GAIG;AACH,SAAS,KAAK,CAAC,GAAW;IACxB,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI,CAAC,CAAC,CAAC;AACnE,CAAC;AAED;;;;GAIG;AACH,MAAM,CAAC,OAAO,CAAC,KAAK,UAAU,SAAS,CAAC,EAAmD;IACzF;;OAEG;IACH,IAAI,KAAK,GAAW,CAAC,CAAC;IAEtB;;OAEG;IACH,IAAI,QAAQ,GAAa,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAEhC;;;OAGG;IACH,OAAO,KAAK,UAAU,KAAK,CAAC,IAAmB;QAC7C,8CAA8C;QAC9C,OAAO,KAAK,EAAE,GAAG,SAAS,EAAE,CAAC;YAC3B,IAAI,CAAC;gBACH;;mBAEG;gBACH,MAAM,OAAO,GAAG,QAAQ;qBACrB,KAAK,EAAE;qBACP,OAAO,EAAE;qBACT,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC;qBACX,MAAM,CAAC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,CAAC,GAAG,GAAG,IAAI,EAAE,CAAC,CAAC,CAAC;gBAExC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACvB,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC;gBACrB,OAAO,MAAM,EAAE,CAAC,IAAI,CAAC,CAAC;YACxB,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX;;mBAEG;gBACH,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;oBACxB,MAAM,CAAC,CAAC;gBACV,CAAC;YACH,CAAC;QACH,CAAC;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IAC/B,CAAC,CAAC;AACJ,CAAC"}

dist/es6/retry.test.js

@@ -34,5 +34,3 @@ import { LogLevel } from "@logtail/types";
         const logs = [getRandomLog()];
-        nock("http://example.com")
-            .get("/")
-            .reply(200, logs);
+        nock("http://example.com").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -46,7 +44,3 @@ const retry = await makeRetry(sync);
         const logs = [getRandomLog()];
-        nock("http://example.com")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(200, logs);
+        nock("http://example.com").get("/").reply(500, "Bad").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -60,9 +54,3 @@ const retry = await makeRetry(sync);
         const logs = [getRandomLog()];
-        nock("http://example.com")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(500, "Bad")
-            .get("/")
-            .reply(200, logs);
+        nock("http://example.com").get("/").reply(500, "Bad").get("/").reply(500, "Bad").get("/").reply(200, logs);
         const sync = makeSync(called);
@@ -69,0 +57,0 @@ const retry = await makeRetry(sync);

dist/es6/retry.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"retry.test.js","sourceRoot":"","sources":["../../src/retry.test.ts"],"names":[],"mappings":"AAAA,OAAO,EAAe,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACvD,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,IAAI,MAAM,MAAM,CAAC;AACxB,OAAO,SAAS,MAAM,SAAS,CAAC;AAEhC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,QAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED,SAAS,QAAQ,CAAC,MAAgB;IAChC,OAAO,KAAK,UAAU,IAAI,CAAC,IAAmB;QAC5C,IAAI;YACF,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;YAC9C,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;aAC9B;YACD,MAAM,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC;SAC5B;QAAC,OAAO,CAAC,EAAE;YACV,MAAM,EAAE,CAAC;YACT,MAAM,CAAC,CAAC;SACT;IACH,CAAC,CAAC;AACJ,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,gCAAgC,EAAE,KAAK,IAAI,EAAE;QAC9C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,IAAI;YACF,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;SACxC;QAAC,WAAM;YACN,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;SACzC;IACH,CAAC,EAAE,IAAI,CAAC,CAAC;AACX,CAAC,CAAC,CAAC"}
+{"version":3,"file":"retry.test.js","sourceRoot":"","sources":["../../src/retry.test.ts"],"names":[],"mappings":"AAAA,OAAO,EAAe,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACvD,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,IAAI,MAAM,MAAM,CAAC;AACxB,OAAO,SAAS,MAAM,SAAS,CAAC;AAEhC;;GAEG;AACH,SAAS,YAAY;IACnB,OAAO;QACL,EAAE,EAAE,IAAI,IAAI,EAAE;QACd,KAAK,EAAE,QAAQ,CAAC,IAAI;QACpB,OAAO,EAAE,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;KAC/B,CAAC;AACJ,CAAC;AAED,SAAS,QAAQ,CAAC,MAAgB;IAChC,OAAO,KAAK,UAAU,IAAI,CAAC,IAAmB;QAC5C,IAAI,CAAC;YACH,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,oBAAoB,CAAC,CAAC;YAC9C,IAAI,GAAG,CAAC,EAAE,EAAE,CAAC;gBACX,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;YAC/B,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,SAAS,CAAC,CAAC;QAC7B,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,MAAM,EAAE,CAAC;YACT,MAAM,CAAC,CAAC;QACV,CAAC;IACH,CAAC,CAAC;AACJ,CAAC;AAED,QAAQ,CAAC,aAAa,EAAE,GAAG,EAAE;IAC3B,EAAE,CAAC,gCAAgC,EAAE,KAAK,IAAI,EAAE;QAC9C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAErD,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEhF,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,iCAAiC,EAAE,KAAK,IAAI,EAAE;QAC/C,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAE3G,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACvC,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;IAC1C,CAAC,EAAE,IAAI,CAAC,CAAC;IAET,EAAE,CAAC,mCAAmC,EAAE,KAAK,IAAI,EAAE;QACjD,MAAM,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACzB,MAAM,IAAI,GAAkB,CAAC,YAAY,EAAE,CAAC,CAAC;QAE7C,IAAI,CAAC,oBAAoB,CAAC;aACvB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,KAAK,CAAC;aACjB,GAAG,CAAC,GAAG,CAAC;aACR,KAAK,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QAEpB,MAAM,IAAI,GAAG,QAAQ,CAAC,MAAM,CAAC,CAAC;QAC9B,MAAM,KAAK,GAAG,MAAM,SAAS,CAAC,IAAI,CAAC,CAAC;QACpC,IAAI,CAAC;YACH,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,CAAC;QACzC,CAAC;QAAC,WAAM,CAAC;YACP,MAAM,CAAC,MAAM,CAAC,CAAC,qBAAqB,CAAC,CAAC,CAAC,CAAC;QAC1C,CAAC;IACH,CAAC,EAAE,IAAI,CAAC,CAAC;AACX,CAAC,CAAC,CAAC"}

dist/es6/throttle.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttle.js","sourceRoot":"","sources":["../../src/throttle.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,SAAS,CAAC;AAG5B;;;GAGG;AACH,MAAM,CAAC,OAAO,UAAU,YAAY,CAAoC,GAAW;IACjF,0BAA0B;IAC1B,IAAI,OAAO,GAAG,CAAC,CAAC;IAEhB,sBAAsB;IACtB,MAAM,KAAK,GAAG,IAAI,KAAK,EAAuB,CAAC;IAE/C;;;OAGG;IACH,SAAS,QAAQ,CAAC,EAAK;QACrB,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBACnD;;mBAEG;gBACH,KAAK,UAAU,OAAO;oBACpB,kDAAkD;oBAClD,IAAI,OAAO,GAAG,GAAG,EAAE;wBACjB,oCAAoC;wBACpC,OAAO,EAAE,CAAC;wBAEV,IAAI;4BACF,4DAA4D;4BAC5D,oEAAoE;4BACpE,OAAO,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC,CAAC;yBAC5B;wBAAC,OAAO,CAAC,EAAE;4BACV,MAAM,CAAC,CAAC,CAAC,CAAC;yBACX;wBAED,6DAA6D;wBAC7D,OAAO,EAAE,CAAC;wBAEV,4DAA4D;wBAC5D,UAAU;wBACV,IAAI,KAAK,CAAC,MAAM,GAAG,CAAC,EAAE;4BACpB,KAAK,CAAC,KAAK,EAAG,EAAE,CAAC;yBAClB;qBACF;yBAAM;wBACL,4DAA4D;wBAC5D,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;qBACrB;gBACH,CAAC;gBAED,2BAA2B;gBAC3B,OAAO,OAAO,EAAE,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;IACJ,CAAC;IAED,+BAA+B;IAC/B,OAAO,QAAQ,CAAC;AAClB,CAAC"}
+{"version":3,"file":"throttle.js","sourceRoot":"","sources":["../../src/throttle.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,SAAS,CAAC;AAG5B;;;GAGG;AACH,MAAM,CAAC,OAAO,UAAU,YAAY,CAAoC,GAAW;IACjF,0BAA0B;IAC1B,IAAI,OAAO,GAAG,CAAC,CAAC;IAEhB,sBAAsB;IACtB,MAAM,KAAK,GAAG,IAAI,KAAK,EAAuB,CAAC;IAE/C;;;OAGG;IACH,SAAS,QAAQ,CAAC,EAAK;QACrB,OAAO,KAAK,EAAE,GAAG,IAAoB,EAAE,EAAE;YACvC,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBACnD;;mBAEG;gBACH,KAAK,UAAU,OAAO;oBACpB,kDAAkD;oBAClD,IAAI,OAAO,GAAG,GAAG,EAAE,CAAC;wBAClB,oCAAoC;wBACpC,OAAO,EAAE,CAAC;wBAEV,IAAI,CAAC;4BACH,4DAA4D;4BAC5D,oEAAoE;4BACpE,OAAO,CAAC,MAAM,EAAE,CAAC,GAAG,IAAI,CAAC,CAAC,CAAC;wBAC7B,CAAC;wBAAC,OAAO,CAAC,EAAE,CAAC;4BACX,MAAM,CAAC,CAAC,CAAC,CAAC;wBACZ,CAAC;wBAED,6DAA6D;wBAC7D,OAAO,EAAE,CAAC;wBAEV,4DAA4D;wBAC5D,UAAU;wBACV,IAAI,KAAK,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;4BACrB,KAAK,CAAC,KAAK,EAAG,EAAE,CAAC;wBACnB,CAAC;oBACH,CAAC;yBAAM,CAAC;wBACN,4DAA4D;wBAC5D,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;oBACtB,CAAC;gBACH,CAAC;gBAED,2BAA2B;gBAC3B,OAAO,OAAO,EAAE,CAAC;YACnB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC;IACJ,CAAC;IAED,+BAA+B;IAC/B,OAAO,QAAQ,CAAC;AAClB,CAAC"}

dist/es6/throttle.test.js

@@ -11,3 +11,3 @@ import makeThrottle from "./throttle";
         // Create the pipeline function to use the throttle
-        const pipeline = throttle(async (log) => new Promise(resolve => {
+        const pipeline = throttle(async (log) => new Promise((resolve) => {
             setTimeout(() => {
@@ -30,3 +30,4 @@ resolve(log);
         const expectedTime = (numberOfPromises / max) * throttleTime;
-        expect(end).toBeGreaterThanOrEqual(expectedTime);
+        const toleranceMilliseconds = 0.2;
+        expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
     });
@@ -33,0 +34,0 @@ it("should handle rejections", async () => {

dist/es6/throttle.test.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"throttle.test.js","sourceRoot":"","sources":["../../src/throttle.test.ts"],"names":[],"mappings":"AAAA,OAAO,YAAY,MAAM,YAAY,CAAC;AAUtC,QAAQ,CAAC,gBAAgB,EAAE,GAAG,EAAE;IAC9B,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,GAAG,GAAG,CAAC,CAAC;QACd,MAAM,YAAY,GAAG,EAAE,CAAC,CAAC,KAAK;QAC9B,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,YAAY,CAAW,GAAG,CAAC,CAAC;QAE7C,mDAAmD;QACnD,MAAM,QAAQ,GAAG,QAAQ,CACvB,KAAK,EAAC,GAAG,EAAC,EAAE,CACV,IAAI,OAAO,CAAO,OAAO,CAAC,EAAE;YAC1B,UAAU,CAAC,GAAG,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,CAAC;YACf,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CACL,CAAC;QAEF,qBAAqB;QACrB,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE;YACzC,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;SAC7C;QAED,mCAAmC;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC;QAE/C,oEAAoE;QACpE,MAAM,YAAY,GAAG,CAAC,gBAAgB,GAAG,GAAG,CAAC,GAAG,YAAY,CAAC;QAE7D,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,CAAC,CAAC;IACnD,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,YAAY,CAAC,CAAC,CAAC,CAAC;QAEjC,gBAAgB;QAChB,IAAI,MAAM,GAAG,CAAC,CAAC;QAEf,4DAA4D;QAC5D,MAAM,QAAQ,GAAG,QAAQ,CAAC,KAAK,EAAC,CAAC,EAAC,EAAE;YAClC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE;gBACd,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;aACtD;YACD,OAAO,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE;YACzC,MAAM,QAAQ,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC;SACzC;QAED,MAAM,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,gBAAgB,GAAG,CAAC,CAAC,CAAC;IAC/C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}
+{"version":3,"file":"throttle.test.js","sourceRoot":"","sources":["../../src/throttle.test.ts"],"names":[],"mappings":"AAAA,OAAO,YAAY,MAAM,YAAY,CAAC;AAUtC,QAAQ,CAAC,gBAAgB,EAAE,GAAG,EAAE;IAC9B,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,GAAG,GAAG,CAAC,CAAC;QACd,MAAM,YAAY,GAAG,EAAE,CAAC,CAAC,KAAK;QAC9B,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,YAAY,CAAW,GAAG,CAAC,CAAC;QAE7C,mDAAmD;QACnD,MAAM,QAAQ,GAAG,QAAQ,CACvB,KAAK,EAAE,GAAG,EAAE,EAAE,CACZ,IAAI,OAAO,CAAO,CAAC,OAAO,EAAE,EAAE;YAC5B,UAAU,CAAC,GAAG,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,CAAC;YACf,CAAC,EAAE,YAAY,CAAC,CAAC;QACnB,CAAC,CAAC,CACL,CAAC;QAEF,qBAAqB;QACrB,MAAM,QAAQ,GAAG,EAAE,CAAC;QAEpB,kBAAkB;QAClB,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAE/B,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE,CAAC;YAC1C,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;QAC9C,CAAC;QAED,mCAAmC;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC;QAE/C,oEAAoE;QACpE,MAAM,YAAY,GAAG,CAAC,gBAAgB,GAAG,GAAG,CAAC,GAAG,YAAY,CAAC;QAC7D,MAAM,qBAAqB,GAAG,GAAG,CAAC;QAElC,MAAM,CAAC,GAAG,CAAC,CAAC,sBAAsB,CAAC,YAAY,GAAG,qBAAqB,CAAC,CAAC;IAC3E,CAAC,CAAC,CAAC;IAEH,EAAE,CAAC,0BAA0B,EAAE,KAAK,IAAI,EAAE;QACxC,WAAW;QACX,MAAM,gBAAgB,GAAG,EAAE,CAAC;QAE5B,+BAA+B;QAC/B,MAAM,QAAQ,GAAG,YAAY,CAAC,CAAC,CAAC,CAAC;QAEjC,gBAAgB;QAChB,IAAI,MAAM,GAAG,CAAC,CAAC;QAEf,4DAA4D;QAC5D,MAAM,QAAQ,GAAG,QAAQ,CAAC,KAAK,EAAE,CAAC,EAAE,EAAE;YACpC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;gBACf,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;YACvD,CAAC;YACD,OAAO,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;QAEH,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,gBAAgB,EAAE,CAAC,EAAE,EAAE,CAAC;YAC1C,MAAM,QAAQ,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC;QAC1C,CAAC;QAED,MAAM,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,gBAAgB,GAAG,CAAC,CAAC,CAAC;IAC/C,CAAC,CAAC,CAAC;AACL,CAAC,CAAC,CAAC"}

package.json

 {
   "name": "@logtail/tools",
-  "version": "0.4.21",
+  "version": "0.5.0",
   "description": "Better Stack JavaScript logging tools (formerly Logtail)",
@@ -31,20 +31,12 @@ "main": "dist/cjs/index.js",
   "devDependencies": {
-    "@types/babel__core": "7.0.4",
-    "@types/babel__traverse": "7.0.4",
-    "@types/jest": "^24.0.17",
     "@types/nock": "^11.1.0",
-    "@types/node": "^12.7.2",
     "@types/source-map": "^0.5.7",
-    "cross-fetch": "^3.0.4",
-    "jest": "^24.9.0",
-    "nock": "^13.3.3",
-    "npm-run-all": "^4.1.5",
-    "prettier": "^1.18.2",
-    "ts-jest": "^24.0.2",
-    "typescript": "^4.9.5"
+    "cross-fetch": "^4.0.0",
+    "nock": "^13.3.3"
   },
   "dependencies": {
-    "@logtail/types": "^0.4.20"
+    "@logtail/types": "^0.5.0",
+    "cross-fetch": "^4.0.0"
   },
-  "gitHead": "8631392d3c7a619a45911ba33ca7ca6b3038e878"
+  "gitHead": "206d52b85903715541e5acbb5b5f1c63298b0714"
 }

README.md

@@ -69,4 +69,4 @@ # [Better Stack](https://betterstack.com/logs) JavaScript client: Helper tools
 // Create a basic pipeline function which resolves after 2 seconds
-const pipeline = async log =>
-  new Promise(resolve => {
+const pipeline = async (log) =>
+  new Promise((resolve) => {
     setTimeout(() => resolve(log), 2000);
@@ -73,0 +73,0 @@ });

src/batch.test.ts

@@ -49,3 +49,3 @@ import nock from "nock";
       .get("/")
-      .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+      .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
 
@@ -66,3 +66,3 @@ const called = jest.fn();
 
-    await Promise.all(logNumberTimes(logger, 5)).catch(e => {
+    await Promise.all(logNumberTimes(logger, 5)).catch((e) => {
       throw e;
@@ -87,3 +87,3 @@ });
 
-    await Promise.all(logNumberTimes(logger, 5)).catch(e => {});
+    await Promise.all(logNumberTimes(logger, 5)).catch((e) => {});
     expect(called).toHaveBeenCalledTimes(4); // 3 retries + 1 initial
@@ -106,3 +106,3 @@ });
 
-    logger(getRandomLog()).catch(e => {});
+    logger(getRandomLog()).catch((e) => {});
     await batcher.flush();
@@ -124,4 +124,4 @@
     // Resolve the throttler after 1 second
-    const throttler = throttle(async logs => {
-      return new Promise(resolve => {
+    const throttler = throttle(async (logs) => {
+      return new Promise((resolve) => {
         setTimeout(() => resolve(logs), throttleResolveAfter);
@@ -159,4 +159,5 @@ });
     const expectedTime = ((numberOfLogs / batchSize) * throttleResolveAfter) / maxThrottle;
+    const toleranceMilliseconds = 0.2;
 
-    expect(end).toBeGreaterThanOrEqual(expectedTime);
+    expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
   });
@@ -167,3 +168,3 @@
       .get("/")
-      .reply(200, new Promise(res => setTimeout(() => res(200), 1003)));
+      .reply(200, new Promise((res) => setTimeout(() => res(200), 1003)));
 
@@ -211,3 +212,3 @@ const called = jest.fn();
     // 100 logs with 50B each is 5000B in total - expecting 10 batches of 500B
-    await Promise.all(logNumberTimes(logger, 100)).catch(e => {
+    await Promise.all(logNumberTimes(logger, 100)).catch((e) => {
       throw e;
@@ -214,0 +215,0 @@ });

src/batch.ts

@@ -79,4 +79,4 @@ import { ILogtailLog } from "@logtail/types";
     try {
-      await cb(currentBuffer.map(d => d.log));
-      currentBuffer.forEach(d => d.resolve(d.log));
+      await cb(currentBuffer.map((d) => d.log));
+      currentBuffer.forEach((d) => d.resolve(d.log));
       retry = 0;
@@ -92,3 +92,3 @@ } catch (e) {
       }
-      currentBuffer.map(d => d.reject(e));
+      currentBuffer.map((d) => d.reject(e));
       retry = 0;
@@ -106,4 +106,4 @@ }
 
-    return new Promise<void>(resolve => {
-      timeout = setTimeout(async function() {
+    return new Promise<void>((resolve) => {
+      timeout = setTimeout(async function () {
         await flush();
@@ -120,3 +120,3 @@ resolve();
   return {
-    initPusher: function(fn: Function) {
+    initPusher: function (fn: Function) {
       cb = fn;
@@ -128,3 +128,3 @@
        */
-      return async function(log: ILogtailLog): Promise<ILogtailLog> {
+      return async function (log: ILogtailLog): Promise<ILogtailLog> {
         return new Promise<ILogtailLog>(async (resolve, reject) => {
@@ -131,0 +131,0 @@ buffer.push({ log, resolve, reject });

src/burstProtection.ts

@@ -34,6 +34,3 @@ import { InferArgs } from "./types";
     const intervalCountSinceLast = Math.floor((now - lastIntervalTime) / intervalLength);
-    callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION))
-      .fill(0)
-      .concat(callCounts)
-      .slice(0, RESOLUTION);
+    callCounts = Array(Math.min(intervalCountSinceLast, RESOLUTION)).fill(0).concat(callCounts).slice(0, RESOLUTION);
     lastIntervalTime += intervalCountSinceLast * intervalLength;
@@ -40,0 +37,0 @@ }

src/queue.test.ts

@@ -28,3 +28,3 @@ import Queue from "./queue";
     // against the values from the queue
-    list.forEach(item => {
+    list.forEach((item) => {
       expect(q.shift()).toEqual(item);
@@ -31,0 +31,0 @@ });

src/retry.test.ts

@@ -37,5 +37,3 @@ import { ILogtailLog, LogLevel } from "@logtail/types";
 
-    nock("http://example.com")
-      .get("/")
-      .reply(200, logs);
+    nock("http://example.com").get("/").reply(200, logs);
 
@@ -52,7 +50,3 @@ const sync = makeSync(called);
 
-    nock("http://example.com")
-      .get("/")
-      .reply(500, "Bad")
-      .get("/")
-      .reply(200, logs);
+    nock("http://example.com").get("/").reply(500, "Bad").get("/").reply(200, logs);
 
@@ -69,9 +63,3 @@ const sync = makeSync(called);
 
-    nock("http://example.com")
-      .get("/")
-      .reply(500, "Bad")
-      .get("/")
-      .reply(500, "Bad")
-      .get("/")
-      .reply(200, logs);
+    nock("http://example.com").get("/").reply(500, "Bad").get("/").reply(500, "Bad").get("/").reply(200, logs);
 
@@ -78,0 +66,0 @@ const sync = makeSync(called);

src/retry.ts

@@ -14,3 +14,3 @@ import { ILogtailLog } from "@logtail/types";
 function delay(sec: number): Promise<any> {
-  return new Promise(resolve => setTimeout(resolve, sec * 1000));
+  return new Promise((resolve) => setTimeout(resolve, sec * 1000));
 }
@@ -17,0 +17,0 @@

src/throttle.test.ts

@@ -23,4 +23,4 @@ import makeThrottle from "./throttle";
     const pipeline = throttle(
-      async log =>
-        new Promise<ILog>(resolve => {
+      async (log) =>
+        new Promise<ILog>((resolve) => {
           setTimeout(() => {
@@ -50,4 +50,5 @@ resolve(log);
     const expectedTime = (numberOfPromises / max) * throttleTime;
+    const toleranceMilliseconds = 0.2;
 
-    expect(end).toBeGreaterThanOrEqual(expectedTime);
+    expect(end).toBeGreaterThanOrEqual(expectedTime - toleranceMilliseconds);
   });
@@ -66,3 +67,3 @@
     // Create a throttled function that will throw half the time
-    const pipeline = throttle(async i => {
+    const pipeline = throttle(async (i) => {
       if (i % 2 == 0) {
@@ -69,0 +70,0 @@ throw new Error("Thrown inside throttled function!");

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

133122

0.64%

Dev dependency count

4

-69.23%

Worsened metrics

Dependency count

2

100%

Lines of code

2445

-1.61%

Dependency changes

• + Added

  cross-fetch@^4.0.0

• + Added

  @logtail/types@0.5.8
  (transitive)

• + Added

  cross-fetch@4.1.0
  (transitive)

• + Added

  node-fetch@2.7.0
  (transitive)

• + Added

  tr46@0.0.3
  (transitive)

• + Added

  webidl-conversions@3.0.1
  (transitive)

• + Added

  whatwg-url@5.0.0
  (transitive)

• - Removed

  @logtail/types@0.4.20
  (transitive)

• Updated

  @logtail/types@^0.5.0