@segment/analytics-core - npm Package Compare versions

Comparing version 1.8.2 to 1.8.3

dist/cjs/priority-queue/index.js

@@ -39,3 +39,2 @@ "use strict";
     PriorityQueue.prototype.pushWithBackoff = function (item, minTimeout) {
-        var _this = this;
         if (minTimeout === void 0) { minTimeout = 0; }
@@ -46,2 +45,13 @@ // One immediate retry unless we have a minimum timeout (e.g. for rate limiting)
         }
+        var timeout = (0, backoff_1.backoff)({ attempt: this.getAttempts(item) });
+        if (minTimeout > 0 && timeout < minTimeout) {
+            timeout = minTimeout;
+        }
+        return this.scheduleItem(item, timeout);
+    };
+    PriorityQueue.prototype.pushWithDelay = function (item, delay) {
+        return this.scheduleItem(item, delay);
+    };
+    PriorityQueue.prototype.scheduleItem = function (item, timeout) {
+        var _this = this;
         var attempt = this.updateAttempts(item);
@@ -51,11 +61,5 @@ if (attempt > this.maxAttempts || this.includes(item)) {
         }
-        var timeout = (0, backoff_1.backoff)({ attempt: attempt - 1 });
-        if (minTimeout > 0 && timeout < minTimeout) {
-            timeout = minTimeout;
-        }
         setTimeout(function () {
             _this.queue.push(item);
-            // remove from future list
             _this.future = _this.future.filter(function (f) { return f.id !== item.id; });
-            // Lets listeners know that a 'future' message is now available in the queue
             _this.emit(exports.ON_REMOVE_FROM_FUTURE);
@@ -62,0 +66,0 @@ }, timeout);

dist/cjs/priority-queue/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":";;;;AAAA,4EAA0D;AAC1D,qCAAmC;AAEnC;;GAEG;AACU,QAAA,qBAAqB,GAAG,oBAAoB,CAAA;AAMzD;IAAuE,yCAAO;IAO5E,uBACE,WAAmB,EACnB,KAAa,EACb,IAA6B;QAH/B,YAKE,iBAAO,SAIR;QAfS,YAAM,GAAW,EAAE,CAAA;QAY3B,KAAI,CAAC,WAAW,GAAG,WAAW,CAAA;QAC9B,KAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,KAAI,CAAC,IAAI,GAAG,IAAI,aAAJ,IAAI,cAAJ,IAAI,GAAI,EAAE,CAAA;;IACxB,CAAC;IAED,4BAAI,GAAJ;QAAA,iBAgBC;QAhBI,eAAgB;aAAhB,UAAgB,EAAhB,qBAAgB,EAAhB,IAAgB;YAAhB,0BAAgB;;QACnB,IAAM,QAAQ,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,SAAS;YACnC,IAAM,QAAQ,GAAG,KAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAA;YAE/C,IAAI,QAAQ,GAAG,KAAI,CAAC,WAAW,IAAI,KAAI,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE;gBAC3D,OAAO,KAAK,CAAA;aACb;YAED,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;YAC1B,OAAO,IAAI,CAAA;QACb,CAAC,CAAC,CAAA;QAEF,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAC1B,UAAC,CAAC,EAAE,CAAC,IAAK,OAAA,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,EAAzC,CAAyC,CACpD,CAAA;QACD,OAAO,QAAQ,CAAA;IACjB,CAAC;IAED,uCAAe,GAAf,UAAgB,IAAU,EAAE,UAAc;QAA1C,iBA2BC;QA3B2B,2BAAA,EAAA,cAAc;QACxC,gFAAgF;QAChF,IAAI,UAAU,IAAI,CAAC,IAAI,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE;YACnD,OAAO,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;SAC1B;QAED,IAAM,OAAO,GAAG,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,CAAA;QAEzC,IAAI,OAAO,GAAG,IAAI,CAAC,WAAW,IAAI,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE;YACrD,OAAO,KAAK,CAAA;SACb;QAED,IAAI,OAAO,GAAG,IAAA,iBAAO,EAAC,EAAE,OAAO,EAAE,OAAO,GAAG,CAAC,EAAE,CAAC,CAAA;QAC/C,IAAI,UAAU,GAAG,CAAC,IAAI,OAAO,GAAG,UAAU,EAAE;YAC1C,OAAO,GAAG,UAAU,CAAA;SACrB;QAED,UAAU,CAAC;YACT,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACrB,0BAA0B;YAC1B,KAAI,CAAC,MAAM,GAAG,KAAI,CAAC,MAAM,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAA;YACzD,4EAA4E;YAC5E,KAAI,CAAC,IAAI,CAAC,6BAAqB,CAAC,CAAA;QAClC,CAAC,EAAE,OAAO,CAAC,CAAA;QAEX,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACtB,OAAO,IAAI,CAAA;IACb,CAAC;IAEM,mCAAW,GAAlB,UAAmB,IAAU;;QAC3B,OAAO,MAAA,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,mCAAI,CAAC,CAAA;IAChC,CAAC;IAEM,sCAAc,GAArB,UAAsB,IAAU;QAC9B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAC/C,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,CAAA;IAC/B,CAAC;IAED,gCAAQ,GAAR,UAAS,IAAU;QACjB,OAAO,CACL,IAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,IAAI,CAAC;YACzB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC;YAC1B,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC;YACjD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC,CACnD,CAAA;IACH,CAAC;IAED,2BAAG,GAAH;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,sBAAW,iCAAM;aAAjB;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAA;QAC1B,CAAC;;;OAAA;IAED,sBAAW,+BAAI;aAAf;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,MAAM,CAAA;QAC/C,CAAC;;;OAAA;IACH,oBAAC;AAAD,CAAC,AA9FD,CAAuE,iCAAO,GA8F7E;AA9FY,sCAAa"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":";;;;AAAA,4EAA0D;AAC1D,qCAAmC;AAEnC;;GAEG;AACU,QAAA,qBAAqB,GAAG,oBAAoB,CAAA;AAMzD;IAAuE,yCAAO;IAO5E,uBACE,WAAmB,EACnB,KAAa,EACb,IAA6B;QAH/B,YAKE,iBAAO,SAIR;QAfS,YAAM,GAAW,EAAE,CAAA;QAY3B,KAAI,CAAC,WAAW,GAAG,WAAW,CAAA;QAC9B,KAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,KAAI,CAAC,IAAI,GAAG,IAAI,aAAJ,IAAI,cAAJ,IAAI,GAAI,EAAE,CAAA;;IACxB,CAAC;IAED,4BAAI,GAAJ;QAAA,iBAgBC;QAhBI,eAAgB;aAAhB,UAAgB,EAAhB,qBAAgB,EAAhB,IAAgB;YAAhB,0BAAgB;;QACnB,IAAM,QAAQ,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,SAAS;YACnC,IAAM,QAAQ,GAAG,KAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAA;YAE/C,IAAI,QAAQ,GAAG,KAAI,CAAC,WAAW,IAAI,KAAI,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE;gBAC3D,OAAO,KAAK,CAAA;aACb;YAED,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;YAC1B,OAAO,IAAI,CAAA;QACb,CAAC,CAAC,CAAA;QAEF,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAC1B,UAAC,CAAC,EAAE,CAAC,IAAK,OAAA,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,EAAzC,CAAyC,CACpD,CAAA;QACD,OAAO,QAAQ,CAAA;IACjB,CAAC;IAED,uCAAe,GAAf,UAAgB,IAAU,EAAE,UAAc;QAAd,2BAAA,EAAA,cAAc;QACxC,gFAAgF;QAChF,IAAI,UAAU,IAAI,CAAC,IAAI,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE;YACnD,OAAO,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;SAC1B;QAED,IAAI,OAAO,GAAG,IAAA,iBAAO,EAAC,EAAE,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;QAC1D,IAAI,UAAU,GAAG,CAAC,IAAI,OAAO,GAAG,UAAU,EAAE;YAC1C,OAAO,GAAG,UAAU,CAAA;SACrB;QAED,OAAO,IAAI,CAAC,YAAY,CAAC,IAAI,EAAE,OAAO,CAAC,CAAA;IACzC,CAAC;IAED,qCAAa,GAAb,UAAc,IAAU,EAAE,KAAa;QACrC,OAAO,IAAI,CAAC,YAAY,CAAC,IAAI,EAAE,KAAK,CAAC,CAAA;IACvC,CAAC;IAEO,oCAAY,GAApB,UAAqB,IAAU,EAAE,OAAe;QAAhD,iBAeC;QAdC,IAAM,OAAO,GAAG,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,CAAA;QAEzC,IAAI,OAAO,GAAG,IAAI,CAAC,WAAW,IAAI,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE;YACrD,OAAO,KAAK,CAAA;SACb;QAED,UAAU,CAAC;YACT,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACrB,KAAI,CAAC,MAAM,GAAG,KAAI,CAAC,MAAM,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAA;YACzD,KAAI,CAAC,IAAI,CAAC,6BAAqB,CAAC,CAAA;QAClC,CAAC,EAAE,OAAO,CAAC,CAAA;QAEX,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACtB,OAAO,IAAI,CAAA;IACb,CAAC;IAEM,mCAAW,GAAlB,UAAmB,IAAU;;QAC3B,OAAO,MAAA,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,mCAAI,CAAC,CAAA;IAChC,CAAC;IAEM,sCAAc,GAArB,UAAsB,IAAU;QAC9B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAC/C,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,CAAA;IAC/B,CAAC;IAED,gCAAQ,GAAR,UAAS,IAAU;QACjB,OAAO,CACL,IAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,IAAI,CAAC;YACzB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC;YAC1B,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC;YACjD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC,CACnD,CAAA;IACH,CAAC;IAED,2BAAG,GAAH;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,sBAAW,iCAAM;aAAjB;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAA;QAC1B,CAAC;;;OAAA;IAED,sBAAW,+BAAI;aAAf;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,MAAM,CAAA;QAC/C,CAAC;;;OAAA;IACH,oBAAC;AAAD,CAAC,AApGD,CAAuE,iCAAO,GAoG7E;AApGY,sCAAa"}

dist/cjs/queue/event-queue.js

@@ -172,17 +172,28 @@ "use strict";
     CoreEventQueue.prototype.deliver = function (ctx) {
+        var _a;
         return tslib_1.__awaiter(this, void 0, void 0, function () {
-            var start, done, err_2, error;
-            return tslib_1.__generator(this, function (_a) {
-                switch (_a.label) {
+            var start, done, failure, error, err_2, error;
+            return tslib_1.__generator(this, function (_b) {
+                switch (_b.label) {
                     case 0: return [4 /*yield*/, this.criticalTasks.done()];
                     case 1:
-                        _a.sent();
+                        _b.sent();
                         start = Date.now();
-                        _a.label = 2;
+                        _b.label = 2;
                     case 2:
-                        _a.trys.push([2, 4, , 5]);
+                        _b.trys.push([2, 4, , 5]);
                         return [4 /*yield*/, this.flushOne(ctx)];
                     case 3:
-                        ctx = _a.sent();
+                        ctx = _b.sent();
                         done = Date.now() - start;
+                        failure = ctx.failedDelivery();
+                        if (failure) {
+                            error = failure.reason instanceof Error
+                                ? failure.reason
+                                : new Error(String((_a = failure.reason) !== null && _a !== void 0 ? _a : 'Unknown delivery failure'));
+                            ctx.log('error', 'Failed to deliver', error);
+                            this.emit('delivery_failure', ctx, error);
+                            ctx.stats.increment('delivery_failed');
+                            return [2 /*return*/, ctx];
+                        }
                         this.emit('delivery_success', ctx);
@@ -193,3 +204,3 @@ ctx.stats.gauge('delivered', done);
                     case 4:
-                        err_2 = _a.sent();
+                        err_2 = _b.sent();
                         error = err_2;
@@ -214,3 +225,3 @@ ctx.log('error', 'Failed to deliver', error);
         return tslib_1.__awaiter(this, void 0, void 0, function () {
-            var ctx, err_3, accepted;
+            var ctx, delivered, err_3, accepted;
             return tslib_1.__generator(this, function (_a) {
@@ -230,6 +241,10 @@ switch (_a.label) {
                         _a.trys.push([1, 3, , 4]);
-                        return [4 /*yield*/, this.deliver(ctx)];
+                        return [4 /*yield*/, this.deliver(ctx)
+                            // deliver() now handles failedDelivery state internally without throwing,
+                            // so we check ctx.failedDelivery() to determine the correct flush status
+                        ];
                     case 2:
                         ctx = _a.sent();
-                        this.emit('flush', ctx, true);
+                        delivered = !ctx.failedDelivery();
+                        this.emit('flush', ctx, delivered);
                         return [3 /*break*/, 4];
@@ -236,0 +251,0 @@ case 3:

dist/cjs/queue/event-queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";;;;AACA,8CAA2C;AAC3C,oDAAwE;AAExE,sCAA4D;AAC5D,4EAA0D;AAG1D,iDAA+D;AAC/D,uCAA4C;AAY5C;IAGU,0CAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,IAAA,4BAAe,GAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,sCAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;;wBAEvB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAEnB,eAAe,GAAG,UAAC,GAAQ;4BAC/B,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,6DAA6D;4BAC7D,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAA;6BAEG,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,eAAe,CAAC,CAAA;;;;wBAM/C,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;;wBAEhC,eAAe,CAAC,KAAG,CAAC,CAAA;;;;;;KAGzB;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,4BAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAA6B;QACvD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GACtB,SAAS,CAAA;YACX,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,IAAA,kBAAO,EAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,IAAA,iBAAM,EAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,IAAA,kBAAO,EAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAnTD,CAGU,iCAAO,GAgThB;AAnTqB,wCAAc"}
+{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";;;;AACA,8CAA2C;AAC3C,oDAAwE;AAExE,sCAA4D;AAC5D,4EAA0D;AAG1D,iDAA+D;AAC/D,uCAA4C;AAY5C;IAGU,0CAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,IAAA,4BAAe,GAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,sCAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;;wBAEvB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAEnB,eAAe,GAAG,UAAC,GAAQ;4BAC/B,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,6DAA6D;4BAC7D,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAA;6BAEG,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,eAAe,CAAC,CAAA;;;;wBAM/C,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;;wBAEhC,eAAe,CAAC,KAAG,CAAC,CAAA;;;;;;KAGzB;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAIzB,OAAO,GAAG,GAAG,CAAC,cAAc,EAAE,CAAA;wBACpC,IAAI,OAAO,EAAE;4BACL,KAAK,GACT,OAAO,CAAC,MAAM,YAAY,KAAK;gCAC7B,CAAC,CAAC,OAAO,CAAC,MAAM;gCAChB,CAAC,CAAC,IAAI,KAAK,CAAC,MAAM,CAAC,MAAA,OAAO,CAAC,MAAM,mCAAI,0BAA0B,CAAC,CAAC,CAAA;4BACrE,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;4BAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;4BACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;4BACtC,sBAAO,GAAG,EAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,4BAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC;4BAC7B,0EAA0E;4BAC1E,yEAAyE;0BAF5C;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAGvB,SAAS,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,CAAA;wBACvC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,SAAS,CAAC,CAAA;;;;wBAE5B,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAA6B;QACvD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GACtB,SAAS,CAAA;YACX,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,IAAA,kBAAO,EAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,IAAA,iBAAM,EAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,IAAA,kBAAO,EAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AArUD,CAGU,iCAAO,GAkUhB;AArUqB,wCAAc"}

dist/esm/priority-queue/index.js

@@ -36,3 +36,2 @@ import { __extends } from "tslib";
     PriorityQueue.prototype.pushWithBackoff = function (item, minTimeout) {
-        var _this = this;
         if (minTimeout === void 0) { minTimeout = 0; }
@@ -43,2 +42,13 @@ // One immediate retry unless we have a minimum timeout (e.g. for rate limiting)
         }
+        var timeout = backoff({ attempt: this.getAttempts(item) });
+        if (minTimeout > 0 && timeout < minTimeout) {
+            timeout = minTimeout;
+        }
+        return this.scheduleItem(item, timeout);
+    };
+    PriorityQueue.prototype.pushWithDelay = function (item, delay) {
+        return this.scheduleItem(item, delay);
+    };
+    PriorityQueue.prototype.scheduleItem = function (item, timeout) {
+        var _this = this;
         var attempt = this.updateAttempts(item);
@@ -48,11 +58,5 @@ if (attempt > this.maxAttempts || this.includes(item)) {
         }
-        var timeout = backoff({ attempt: attempt - 1 });
-        if (minTimeout > 0 && timeout < minTimeout) {
-            timeout = minTimeout;
-        }
         setTimeout(function () {
             _this.queue.push(item);
-            // remove from future list
             _this.future = _this.future.filter(function (f) { return f.id !== item.id; });
-            // Lets listeners know that a 'future' message is now available in the queue
             _this.emit(ON_REMOVE_FROM_FUTURE);
@@ -59,0 +63,0 @@ }, timeout);

dist/esm/priority-queue/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":";AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAC1D,OAAO,EAAE,OAAO,EAAE,MAAM,WAAW,CAAA;AAEnC;;GAEG;AACH,MAAM,CAAC,IAAM,qBAAqB,GAAG,oBAAoB,CAAA;AAMzD;IAAuE,iCAAO;IAO5E,uBACE,WAAmB,EACnB,KAAa,EACb,IAA6B;QAH/B,YAKE,iBAAO,SAIR;QAfS,YAAM,GAAW,EAAE,CAAA;QAY3B,KAAI,CAAC,WAAW,GAAG,WAAW,CAAA;QAC9B,KAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,KAAI,CAAC,IAAI,GAAG,IAAI,aAAJ,IAAI,cAAJ,IAAI,GAAI,EAAE,CAAA;;IACxB,CAAC;IAED,4BAAI,GAAJ;QAAA,iBAgBC;QAhBI,eAAgB;aAAhB,UAAgB,EAAhB,qBAAgB,EAAhB,IAAgB;YAAhB,0BAAgB;;QACnB,IAAM,QAAQ,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,SAAS;YACnC,IAAM,QAAQ,GAAG,KAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAA;YAE/C,IAAI,QAAQ,GAAG,KAAI,CAAC,WAAW,IAAI,KAAI,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE;gBAC3D,OAAO,KAAK,CAAA;aACb;YAED,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;YAC1B,OAAO,IAAI,CAAA;QACb,CAAC,CAAC,CAAA;QAEF,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAC1B,UAAC,CAAC,EAAE,CAAC,IAAK,OAAA,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,EAAzC,CAAyC,CACpD,CAAA;QACD,OAAO,QAAQ,CAAA;IACjB,CAAC;IAED,uCAAe,GAAf,UAAgB,IAAU,EAAE,UAAc;QAA1C,iBA2BC;QA3B2B,2BAAA,EAAA,cAAc;QACxC,gFAAgF;QAChF,IAAI,UAAU,IAAI,CAAC,IAAI,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE;YACnD,OAAO,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;SAC1B;QAED,IAAM,OAAO,GAAG,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,CAAA;QAEzC,IAAI,OAAO,GAAG,IAAI,CAAC,WAAW,IAAI,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE;YACrD,OAAO,KAAK,CAAA;SACb;QAED,IAAI,OAAO,GAAG,OAAO,CAAC,EAAE,OAAO,EAAE,OAAO,GAAG,CAAC,EAAE,CAAC,CAAA;QAC/C,IAAI,UAAU,GAAG,CAAC,IAAI,OAAO,GAAG,UAAU,EAAE;YAC1C,OAAO,GAAG,UAAU,CAAA;SACrB;QAED,UAAU,CAAC;YACT,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACrB,0BAA0B;YAC1B,KAAI,CAAC,MAAM,GAAG,KAAI,CAAC,MAAM,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAA;YACzD,4EAA4E;YAC5E,KAAI,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAA;QAClC,CAAC,EAAE,OAAO,CAAC,CAAA;QAEX,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACtB,OAAO,IAAI,CAAA;IACb,CAAC;IAEM,mCAAW,GAAlB,UAAmB,IAAU;;QAC3B,OAAO,MAAA,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,mCAAI,CAAC,CAAA;IAChC,CAAC;IAEM,sCAAc,GAArB,UAAsB,IAAU;QAC9B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAC/C,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,CAAA;IAC/B,CAAC;IAED,gCAAQ,GAAR,UAAS,IAAU;QACjB,OAAO,CACL,IAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,IAAI,CAAC;YACzB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC;YAC1B,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC;YACjD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC,CACnD,CAAA;IACH,CAAC;IAED,2BAAG,GAAH;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,sBAAW,iCAAM;aAAjB;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAA;QAC1B,CAAC;;;OAAA;IAED,sBAAW,+BAAI;aAAf;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,MAAM,CAAA;QAC/C,CAAC;;;OAAA;IACH,oBAAC;AAAD,CAAC,AA9FD,CAAuE,OAAO,GA8F7E"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":";AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAC1D,OAAO,EAAE,OAAO,EAAE,MAAM,WAAW,CAAA;AAEnC;;GAEG;AACH,MAAM,CAAC,IAAM,qBAAqB,GAAG,oBAAoB,CAAA;AAMzD;IAAuE,iCAAO;IAO5E,uBACE,WAAmB,EACnB,KAAa,EACb,IAA6B;QAH/B,YAKE,iBAAO,SAIR;QAfS,YAAM,GAAW,EAAE,CAAA;QAY3B,KAAI,CAAC,WAAW,GAAG,WAAW,CAAA;QAC9B,KAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,KAAI,CAAC,IAAI,GAAG,IAAI,aAAJ,IAAI,cAAJ,IAAI,GAAI,EAAE,CAAA;;IACxB,CAAC;IAED,4BAAI,GAAJ;QAAA,iBAgBC;QAhBI,eAAgB;aAAhB,UAAgB,EAAhB,qBAAgB,EAAhB,IAAgB;YAAhB,0BAAgB;;QACnB,IAAM,QAAQ,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,SAAS;YACnC,IAAM,QAAQ,GAAG,KAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAA;YAE/C,IAAI,QAAQ,GAAG,KAAI,CAAC,WAAW,IAAI,KAAI,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE;gBAC3D,OAAO,KAAK,CAAA;aACb;YAED,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,CAAA;YAC1B,OAAO,IAAI,CAAA;QACb,CAAC,CAAC,CAAA;QAEF,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAC1B,UAAC,CAAC,EAAE,CAAC,IAAK,OAAA,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC,EAAzC,CAAyC,CACpD,CAAA;QACD,OAAO,QAAQ,CAAA;IACjB,CAAC;IAED,uCAAe,GAAf,UAAgB,IAAU,EAAE,UAAc;QAAd,2BAAA,EAAA,cAAc;QACxC,gFAAgF;QAChF,IAAI,UAAU,IAAI,CAAC,IAAI,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE;YACnD,OAAO,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAA;SAC1B;QAED,IAAI,OAAO,GAAG,OAAO,CAAC,EAAE,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;QAC1D,IAAI,UAAU,GAAG,CAAC,IAAI,OAAO,GAAG,UAAU,EAAE;YAC1C,OAAO,GAAG,UAAU,CAAA;SACrB;QAED,OAAO,IAAI,CAAC,YAAY,CAAC,IAAI,EAAE,OAAO,CAAC,CAAA;IACzC,CAAC;IAED,qCAAa,GAAb,UAAc,IAAU,EAAE,KAAa;QACrC,OAAO,IAAI,CAAC,YAAY,CAAC,IAAI,EAAE,KAAK,CAAC,CAAA;IACvC,CAAC;IAEO,oCAAY,GAApB,UAAqB,IAAU,EAAE,OAAe;QAAhD,iBAeC;QAdC,IAAM,OAAO,GAAG,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,CAAA;QAEzC,IAAI,OAAO,GAAG,IAAI,CAAC,WAAW,IAAI,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE;YACrD,OAAO,KAAK,CAAA;SACb;QAED,UAAU,CAAC;YACT,KAAI,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YACrB,KAAI,CAAC,MAAM,GAAG,KAAI,CAAC,MAAM,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAA;YACzD,KAAI,CAAC,IAAI,CAAC,qBAAqB,CAAC,CAAA;QAClC,CAAC,EAAE,OAAO,CAAC,CAAA;QAEX,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;QACtB,OAAO,IAAI,CAAA;IACb,CAAC;IAEM,mCAAW,GAAlB,UAAmB,IAAU;;QAC3B,OAAO,MAAA,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,mCAAI,CAAC,CAAA;IAChC,CAAC;IAEM,sCAAc,GAArB,UAAsB,IAAU;QAC9B,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,GAAG,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAC/C,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,CAAA;IAC/B,CAAC;IAED,gCAAQ,GAAR,UAAS,IAAU;QACjB,OAAO,CACL,IAAI,CAAC,KAAK,CAAC,QAAQ,CAAC,IAAI,CAAC;YACzB,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC;YAC1B,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC;YACjD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,EAAhB,CAAgB,CAAC,CAAC,CACnD,CAAA;IACH,CAAC;IAED,2BAAG,GAAH;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,sBAAW,iCAAM;aAAjB;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAA;QAC1B,CAAC;;;OAAA;IAED,sBAAW,+BAAI;aAAf;YACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,MAAM,CAAA;QAC/C,CAAC;;;OAAA;IACH,oBAAC;AAAD,CAAC,AApGD,CAAuE,OAAO,GAoG7E"}

dist/esm/queue/event-queue.js

@@ -169,17 +169,28 @@ import { __awaiter, __extends, __generator } from "tslib";
     CoreEventQueue.prototype.deliver = function (ctx) {
+        var _a;
         return __awaiter(this, void 0, void 0, function () {
-            var start, done, err_2, error;
-            return __generator(this, function (_a) {
-                switch (_a.label) {
+            var start, done, failure, error, err_2, error;
+            return __generator(this, function (_b) {
+                switch (_b.label) {
                     case 0: return [4 /*yield*/, this.criticalTasks.done()];
                     case 1:
-                        _a.sent();
+                        _b.sent();
                         start = Date.now();
-                        _a.label = 2;
+                        _b.label = 2;
                     case 2:
-                        _a.trys.push([2, 4, , 5]);
+                        _b.trys.push([2, 4, , 5]);
                         return [4 /*yield*/, this.flushOne(ctx)];
                     case 3:
-                        ctx = _a.sent();
+                        ctx = _b.sent();
                         done = Date.now() - start;
+                        failure = ctx.failedDelivery();
+                        if (failure) {
+                            error = failure.reason instanceof Error
+                                ? failure.reason
+                                : new Error(String((_a = failure.reason) !== null && _a !== void 0 ? _a : 'Unknown delivery failure'));
+                            ctx.log('error', 'Failed to deliver', error);
+                            this.emit('delivery_failure', ctx, error);
+                            ctx.stats.increment('delivery_failed');
+                            return [2 /*return*/, ctx];
+                        }
                         this.emit('delivery_success', ctx);
@@ -190,3 +201,3 @@ ctx.stats.gauge('delivered', done);
                     case 4:
-                        err_2 = _a.sent();
+                        err_2 = _b.sent();
                         error = err_2;
@@ -211,3 +222,3 @@ ctx.log('error', 'Failed to deliver', error);
         return __awaiter(this, void 0, void 0, function () {
-            var ctx, err_3, accepted;
+            var ctx, delivered, err_3, accepted;
             return __generator(this, function (_a) {
@@ -227,6 +238,10 @@ switch (_a.label) {
                         _a.trys.push([1, 3, , 4]);
-                        return [4 /*yield*/, this.deliver(ctx)];
+                        return [4 /*yield*/, this.deliver(ctx)
+                            // deliver() now handles failedDelivery state internally without throwing,
+                            // so we check ctx.failedDelivery() to determine the correct flush status
+                        ];
                     case 2:
                         ctx = _a.sent();
-                        this.emit('flush', ctx, true);
+                        delivered = !ctx.failedDelivery();
+                        this.emit('flush', ctx, delivered);
                         return [3 /*break*/, 4];
@@ -233,0 +248,0 @@ case 3:

dist/esm/queue/event-queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";AACA,OAAO,EAAE,OAAO,EAAE,MAAM,mBAAmB,CAAA;AAC3C,OAAO,EAAE,qBAAqB,EAAiB,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D,OAAO,EAAE,eAAe,EAAa,MAAM,oBAAoB,CAAA;AAC/D,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,MAAM,YAAY,CAAA;AAY5C;IAGU,kCAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,eAAe,EAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,qBAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;;wBAEvB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAEnB,eAAe,GAAG,UAAC,GAAQ;4BAC/B,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,6DAA6D;4BAC7D,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAA;6BAEG,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,eAAe,CAAC,CAAA;;;;wBAM/C,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;;wBAEhC,eAAe,CAAC,KAAG,CAAC,CAAA;;;;;;KAGzB;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,kBAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAA6B;QACvD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GACtB,SAAS,CAAA;YACX,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,OAAO,CAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,MAAM,CAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,OAAO,CAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,OAAO,CAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,OAAO,CAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAnTD,CAGU,OAAO,GAgThB"}
+{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";AACA,OAAO,EAAE,OAAO,EAAE,MAAM,mBAAmB,CAAA;AAC3C,OAAO,EAAE,qBAAqB,EAAiB,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D,OAAO,EAAE,eAAe,EAAa,MAAM,oBAAoB,CAAA;AAC/D,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,MAAM,YAAY,CAAA;AAY5C;IAGU,kCAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,eAAe,EAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,qBAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;;wBAEvB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAEnB,eAAe,GAAG,UAAC,GAAQ;4BAC/B,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,6DAA6D;4BAC7D,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAA;6BAEG,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,eAAe,CAAC,CAAA;;;;wBAM/C,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;;wBAEhC,eAAe,CAAC,KAAG,CAAC,CAAA;;;;;;KAGzB;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAIzB,OAAO,GAAG,GAAG,CAAC,cAAc,EAAE,CAAA;wBACpC,IAAI,OAAO,EAAE;4BACL,KAAK,GACT,OAAO,CAAC,MAAM,YAAY,KAAK;gCAC7B,CAAC,CAAC,OAAO,CAAC,MAAM;gCAChB,CAAC,CAAC,IAAI,KAAK,CAAC,MAAM,CAAC,MAAA,OAAO,CAAC,MAAM,mCAAI,0BAA0B,CAAC,CAAC,CAAA;4BACrE,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;4BAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;4BACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;4BACtC,sBAAO,GAAG,EAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,kBAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC;4BAC7B,0EAA0E;4BAC1E,yEAAyE;0BAF5C;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAGvB,SAAS,GAAG,CAAC,GAAG,CAAC,cAAc,EAAE,CAAA;wBACvC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,SAAS,CAAC,CAAA;;;;wBAE5B,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAA6B;QACvD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GACtB,SAAS,CAAA;YACX,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,OAAO,CAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,MAAM,CAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,OAAO,CAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,OAAO,CAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,OAAO,CAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AArUD,CAGU,OAAO,GAkUhB"}

dist/types/priority-queue/index.d.ts

@@ -17,2 +17,4 @@ import { Emitter } from '@segment/analytics-generic-utils';
     pushWithBackoff(item: Item, minTimeout?: number): boolean;
+    pushWithDelay(item: Item, delay: number): boolean;
+    private scheduleItem;
     getAttempts(item: Item): number;
@@ -19,0 +21,0 @@ updateAttempts(item: Item): number;

dist/types/priority-queue/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D;;GAEG;AACH,eAAO,MAAM,qBAAqB,uBAAuB,CAAA;AAEzD,UAAU,SAAS;IACjB,EAAE,EAAE,MAAM,CAAA;CACX;AAED,qBAAa,aAAa,CAAC,IAAI,SAAS,SAAS,GAAG,SAAS,CAAE,SAAQ,OAAO;IAC5E,SAAS,CAAC,MAAM,EAAE,IAAI,EAAE,CAAK;IAC7B,SAAS,CAAC,KAAK,EAAE,IAAI,EAAE,CAAA;IACvB,SAAS,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAA;IAE/B,WAAW,EAAE,MAAM,CAAA;gBAGxB,WAAW,EAAE,MAAM,EACnB,KAAK,EAAE,IAAI,EAAE,EACb,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC;IAQ/B,IAAI,CAAC,GAAG,KAAK,EAAE,IAAI,EAAE,GAAG,OAAO,EAAE;IAkBjC,eAAe,CAAC,IAAI,EAAE,IAAI,EAAE,UAAU,SAAI,GAAG,OAAO;IA6B7C,WAAW,CAAC,IAAI,EAAE,IAAI,GAAG,MAAM;IAI/B,cAAc,CAAC,IAAI,EAAE,IAAI,GAAG,MAAM;IAKzC,QAAQ,CAAC,IAAI,EAAE,IAAI,GAAG,OAAO;IAS7B,GAAG,IAAI,IAAI,GAAG,SAAS;IAIvB,IAAW,MAAM,IAAI,MAAM,CAE1B;IAED,IAAW,IAAI,IAAI,MAAM,CAExB;CACF"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/priority-queue/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D;;GAEG;AACH,eAAO,MAAM,qBAAqB,uBAAuB,CAAA;AAEzD,UAAU,SAAS;IACjB,EAAE,EAAE,MAAM,CAAA;CACX;AAED,qBAAa,aAAa,CAAC,IAAI,SAAS,SAAS,GAAG,SAAS,CAAE,SAAQ,OAAO;IAC5E,SAAS,CAAC,MAAM,EAAE,IAAI,EAAE,CAAK;IAC7B,SAAS,CAAC,KAAK,EAAE,IAAI,EAAE,CAAA;IACvB,SAAS,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAA;IAE/B,WAAW,EAAE,MAAM,CAAA;gBAGxB,WAAW,EAAE,MAAM,EACnB,KAAK,EAAE,IAAI,EAAE,EACb,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC;IAQ/B,IAAI,CAAC,GAAG,KAAK,EAAE,IAAI,EAAE,GAAG,OAAO,EAAE;IAkBjC,eAAe,CAAC,IAAI,EAAE,IAAI,EAAE,UAAU,SAAI,GAAG,OAAO;IAcpD,aAAa,CAAC,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,GAAG,OAAO;IAIjD,OAAO,CAAC,YAAY;IAiBb,WAAW,CAAC,IAAI,EAAE,IAAI,GAAG,MAAM;IAI/B,cAAc,CAAC,IAAI,EAAE,IAAI,GAAG,MAAM;IAKzC,QAAQ,CAAC,IAAI,EAAE,IAAI,GAAG,OAAO;IAS7B,GAAG,IAAI,IAAI,GAAG,SAAS;IAIvB,IAAW,MAAM,IAAI,MAAM,CAE1B;IAED,IAAW,IAAI,IAAI,MAAM,CAExB;CACF"}

dist/types/queue/event-queue.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.d.ts","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,cAAc,CAAA;AAE5C,OAAO,EAAyB,aAAa,EAAE,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAE1D,OAAO,EAAE,UAAU,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,EAAmB,SAAS,EAAE,MAAM,oBAAoB,CAAA;AAG/D,MAAM,MAAM,yBAAyB,CAAC,GAAG,SAAS,WAAW,IAAI;IAC/D,iBAAiB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC7B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;IACrD,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC5B,cAAc,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC1B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,GAAG,KAAK,GAAG,kBAAkB,CAAC,CAAA;IACnE,KAAK,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,SAAS,EAAE,OAAO,CAAC,CAAA;IACrC,sBAAsB,EAAE,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;CAC1C,CAAA;AAED,8BAAsB,cAAc,CAClC,GAAG,SAAS,WAAW,GAAG,WAAW,EACrC,MAAM,SAAS,UAAU,CAAC,GAAG,CAAC,GAAG,UAAU,CAAC,GAAG,CAAC,CAChD,SAAQ,OAAO,CAAC,yBAAyB,CAAC,GAAG,CAAC,CAAC;IAC/C;;;;;;OAMG;IACH,aAAa,EAAE,SAAS,CAAoB;IAC5C,KAAK,EAAE,aAAa,CAAC,GAAG,CAAC,CAAA;IACzB,OAAO,EAAE,MAAM,EAAE,CAAK;IACtB,qBAAqB,EAAE,MAAM,EAAE,CAAK;IACpC,OAAO,CAAC,QAAQ,CAAQ;gBAEZ,aAAa,EAAE,aAAa,CAAC,GAAG,CAAC;IASvC,QAAQ,CACZ,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,MAAM,EACd,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IA+BV,UAAU,CACd,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,EACvB,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAeV,QAAQ,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;YAUxB,mBAAmB;IAiB3B,cAAc,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAkB5C,OAAO,IAAI,OAAO;IAIlB,OAAO,CAAC,aAAa;YAqBP,OAAO;IAoBrB,OAAO,CAAC,WAAW;IASb,KAAK,IAAI,OAAO,CAAC,GAAG,EAAE,CAAC;IA6B7B,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,mBAAmB;YAsCb,QAAQ;CAuDvB"}
+{"version":3,"file":"event-queue.d.ts","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,cAAc,CAAA;AAE5C,OAAO,EAAyB,aAAa,EAAE,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAE1D,OAAO,EAAE,UAAU,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,EAAmB,SAAS,EAAE,MAAM,oBAAoB,CAAA;AAG/D,MAAM,MAAM,yBAAyB,CAAC,GAAG,SAAS,WAAW,IAAI;IAC/D,iBAAiB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC7B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;IACrD,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC5B,cAAc,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC1B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,GAAG,KAAK,GAAG,kBAAkB,CAAC,CAAA;IACnE,KAAK,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,SAAS,EAAE,OAAO,CAAC,CAAA;IACrC,sBAAsB,EAAE,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;CAC1C,CAAA;AAED,8BAAsB,cAAc,CAClC,GAAG,SAAS,WAAW,GAAG,WAAW,EACrC,MAAM,SAAS,UAAU,CAAC,GAAG,CAAC,GAAG,UAAU,CAAC,GAAG,CAAC,CAChD,SAAQ,OAAO,CAAC,yBAAyB,CAAC,GAAG,CAAC,CAAC;IAC/C;;;;;;OAMG;IACH,aAAa,EAAE,SAAS,CAAoB;IAC5C,KAAK,EAAE,aAAa,CAAC,GAAG,CAAC,CAAA;IACzB,OAAO,EAAE,MAAM,EAAE,CAAK;IACtB,qBAAqB,EAAE,MAAM,EAAE,CAAK;IACpC,OAAO,CAAC,QAAQ,CAAQ;gBAEZ,aAAa,EAAE,aAAa,CAAC,GAAG,CAAC;IASvC,QAAQ,CACZ,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,MAAM,EACd,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IA+BV,UAAU,CACd,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,EACvB,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAeV,QAAQ,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;YAUxB,mBAAmB;IAiB3B,cAAc,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAkB5C,OAAO,IAAI,OAAO;IAIlB,OAAO,CAAC,aAAa;YAqBP,OAAO;IAmCrB,OAAO,CAAC,WAAW;IASb,KAAK,IAAI,OAAO,CAAC,GAAG,EAAE,CAAC;IAgC7B,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,mBAAmB;YAsCb,QAAQ;CAuDvB"}

package.json

 {
   "name": "@segment/analytics-core",
-  "version": "1.8.2",
+  "version": "1.8.3",
   "repository": {
@@ -5,0 +5,0 @@ "type": "git",

src/priority-queue/index.ts

@@ -55,2 +55,15 @@ import { Emitter } from '@segment/analytics-generic-utils'
 
+    let timeout = backoff({ attempt: this.getAttempts(item) })
+    if (minTimeout > 0 && timeout < minTimeout) {
+      timeout = minTimeout
+    }
+
+    return this.scheduleItem(item, timeout)
+  }
+
+  pushWithDelay(item: Item, delay: number): boolean {
+    return this.scheduleItem(item, delay)
+  }
+
+  private scheduleItem(item: Item, timeout: number): boolean {
     const attempt = this.updateAttempts(item)
@@ -62,12 +75,5 @@
 
-    let timeout = backoff({ attempt: attempt - 1 })
-    if (minTimeout > 0 && timeout < minTimeout) {
-      timeout = minTimeout
-    }
-
     setTimeout(() => {
       this.queue.push(item)
-      // remove from future list
       this.future = this.future.filter((f) => f.id !== item.id)
-      // Lets listeners know that a 'future' message is now available in the queue
       this.emit(ON_REMOVE_FROM_FUTURE)
@@ -74,0 +80,0 @@ }, timeout)

src/queue/event-queue.ts

@@ -179,2 +179,17 @@ import { CoreAnalytics } from '../analytics'
       const done = Date.now() - start
+
+      // Check if any plugin marked delivery as failed without throwing
+      // (e.g., the Node SDK's Publisher resolves with failedDelivery set on rate limiting)
+      const failure = ctx.failedDelivery()
+      if (failure) {
+        const error =
+          failure.reason instanceof Error
+            ? failure.reason
+            : new Error(String(failure.reason ?? 'Unknown delivery failure'))
+        ctx.log('error', 'Failed to deliver', error)
+        this.emit('delivery_failure', ctx, error)
+        ctx.stats.increment('delivery_failed')
+        return ctx
+      }
+
       this.emit('delivery_success', ctx)
@@ -216,3 +231,6 @@ ctx.stats.gauge('delivered', done)
       ctx = await this.deliver(ctx)
-      this.emit('flush', ctx, true)
+      // deliver() now handles failedDelivery state internally without throwing,
+      // so we check ctx.failedDelivery() to determine the correct flush status
+      const delivered = !ctx.failedDelivery()
+      this.emit('flush', ctx, delivered)
     } catch (err: any) {
@@ -219,0 +237,0 @@ const accepted = this.enqueuRetry(err, ctx)

No alert changes

Improved metrics

Total package byte prevSize

295702

1.62%

Lines of code

5248

1.16%

No dependency changes