queue-cb - npm Package Compare versions

Comparing version 1.5.11 to 1.6.0

dist/cjs/index.d.cts

@@ -8,2 +8,3 @@ export type DeferCallback = (error?: Error) => void;
     private _callAwait;
+    private _drainQueue;
     private _callDefer;
@@ -10,0 +11,0 @@ defer(defer: DeferFunction): void;

dist/cjs/index.d.ts

@@ -8,2 +8,3 @@ export type DeferCallback = (error?: Error) => void;
     private _callAwait;
+    private _drainQueue;
     private _callDefer;
@@ -10,0 +11,0 @@ defer(defer: DeferFunction): void;

dist/cjs/index.js

@@ -22,2 +22,10 @@ "use strict";
 }
+// Threshold for synchronous callbacks before yielding to event loop
+// This prevents stack overflow while minimizing async overhead
+var SYNC_DEPTH_THRESHOLD = 1000;
+// Cross-platform async scheduler (Node 0.8+ compatible)
+// setImmediate is preferred (Node 0.10+), falls back to setTimeout for Node 0.8
+var scheduleAsync = typeof setImmediate === 'function' ? setImmediate : function(fn) {
+    return setTimeout(fn, 0);
+};
 var Queue = /*#__PURE__*/ function() {
@@ -34,6 +42,8 @@ "use strict";
             awaitCallback: null,
-            awaitCalled: false
+            awaitCalled: false,
+            syncDepth: 0
         };
         this._callAwait = this._callAwait.bind(this);
         this._callDefer = this._callDefer.bind(this);
+        this._drainQueue = this._drainQueue.bind(this);
     }
@@ -46,2 +56,11 @@ var _proto = Queue.prototype;
     };
+    _proto._drainQueue = function _drainQueue() {
+        // Reset sync depth when we enter from async context
+        this._state.syncDepth = 0;
+        // Process all available tasks up to parallelism limit
+        while(!this._state.error && this._state.tasks.length && this._state.runningCount < this._state.parallelism){
+            this._state.runningCount++;
+            this._state.tasks.shift()(this._callDefer);
+        }
+    };
     _proto._callDefer = function _callDefer(err) {
@@ -52,2 +71,8 @@ this._state.runningCount--;
         if (!this._state.tasks.length) return;
+        // Trampoline: yield to event loop periodically to prevent stack overflow
+        this._state.syncDepth++;
+        if (this._state.syncDepth >= SYNC_DEPTH_THRESHOLD) {
+            scheduleAsync(this._drainQueue);
+            return;
+        }
         this._state.runningCount++;
@@ -54,0 +79,0 @@ this._state.tasks.shift()(this._callDefer);

dist/cjs/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/utils/queue-cb/src/index.ts"],"sourcesContent":["import LinkedArray from './LinkedArray.ts';\n\nexport type DeferCallback = (error?: Error) => void;\nexport type DeferFunction = (calback: DeferCallback) => void;\nexport type AwaitCallback = (error?: Error) => void;\n\ninterface QueueState {\n  parallelism: number;\n  tasks: LinkedArray<DeferFunction>;\n  runningCount: number;\n  error: Error | null;\n  awaitCalled: boolean;\n  awaitCallback: AwaitCallback | null;\n}\n\nexport default class Queue {\n  private _state: QueueState;\n\n  constructor(parallelism: number = Infinity) {\n    this._state = {\n      parallelism,\n      tasks: new LinkedArray(),\n      runningCount: 0,\n      error: null,\n      awaitCallback: null,\n      awaitCalled: false,\n    };\n    this._callAwait = this._callAwait.bind(this);\n    this._callDefer = this._callDefer.bind(this);\n  }\n\n  private _callAwait() {\n    if (this._state.awaitCalled || !this._state.awaitCallback) return;\n    this._state.awaitCalled = true;\n    return this._state.awaitCallback(this._state.error);\n  }\n\n  private _callDefer(err?: Error) {\n    this._state.runningCount--;\n    if (err && !this._state.error) this._state.error = err;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n    if (!this._state.tasks.length) return;\n    this._state.runningCount++;\n    this._state.tasks.shift()(this._callDefer);\n  }\n\n  defer(defer: DeferFunction) {\n    if (this._state.error) return;\n    if (this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      defer(this._callDefer);\n    } else this._state.tasks.push(defer);\n  }\n\n  await(callback: AwaitCallback) {\n    if (this._state.awaitCallback) throw new Error(`Awaiting callback was added twice: ${callback}`);\n    this._state.awaitCallback = callback;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n  }\n}\n"],"names":["Queue","parallelism","Infinity","_state","tasks","LinkedArray","runningCount","error","awaitCallback","awaitCalled","_callAwait","bind","_callDefer","err","length","shift","defer","push","await","callback","Error"],"mappings":";;;;;;;eAeqBA;;;oEAfG;;;;;;;;;;;AAeT,IAAA,AAAMA,sBAAN;;aAAMA;YAGPC,cAAAA,iEAAsBC;gCAHfF;QAIjB,IAAI,CAACG,MAAM,GAAG;YACZF,aAAAA;YACAG,OAAO,IAAIC,sBAAW;YACtBC,cAAc;YACdC,OAAO;YACPC,eAAe;YACfC,aAAa;QACf;QACA,IAAI,CAACC,UAAU,GAAG,IAAI,CAACA,UAAU,CAACC,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACC,UAAU,GAAG,IAAI,CAACA,UAAU,CAACD,IAAI,CAAC,IAAI;;iBAb1BX;IAgBnB,OAAQU,UAIP,GAJD,SAAQA;QACN,IAAI,IAAI,CAACP,MAAM,CAACM,WAAW,IAAI,CAAC,IAAI,CAACN,MAAM,CAACK,aAAa,EAAE;QAC3D,IAAI,CAACL,MAAM,CAACM,WAAW,GAAG;QAC1B,OAAO,IAAI,CAACN,MAAM,CAACK,aAAa,CAAC,IAAI,CAACL,MAAM,CAACI,KAAK;IACpD;IAEA,OAAQK,UAOP,GAPD,SAAQA,WAAWC,GAAW;QAC5B,IAAI,CAACV,MAAM,CAACG,YAAY;QACxB,IAAIO,OAAO,CAAC,IAAI,CAACV,MAAM,CAACI,KAAK,EAAE,IAAI,CAACJ,MAAM,CAACI,KAAK,GAAGM;QACnD,IAAI,IAAI,CAACV,MAAM,CAACI,KAAK,IAAI,CAAE,CAAA,IAAI,CAACJ,MAAM,CAACC,KAAK,CAACU,MAAM,GAAG,IAAI,CAACX,MAAM,CAACG,YAAY,AAAD,GAAI,OAAO,IAAI,CAACI,UAAU;QACvG,IAAI,CAAC,IAAI,CAACP,MAAM,CAACC,KAAK,CAACU,MAAM,EAAE;QAC/B,IAAI,CAACX,MAAM,CAACG,YAAY;QACxB,IAAI,CAACH,MAAM,CAACC,KAAK,CAACW,KAAK,GAAG,IAAI,CAACH,UAAU;IAC3C;IAEAI,OAAAA,KAMC,GANDA,SAAAA,MAAMA,KAAoB;QACxB,IAAI,IAAI,CAACb,MAAM,CAACI,KAAK,EAAE;QACvB,IAAI,IAAI,CAACJ,MAAM,CAACG,YAAY,GAAG,IAAI,CAACH,MAAM,CAACF,WAAW,EAAE;YACtD,IAAI,CAACE,MAAM,CAACG,YAAY;YACxBU,MAAM,IAAI,CAACJ,UAAU;QACvB,OAAO,IAAI,CAACT,MAAM,CAACC,KAAK,CAACa,IAAI,CAACD;IAChC;IAEAE,OAAAA,KAIC,GAJDA,SAAAA,OAAMC,QAAuB;QAC3B,IAAI,IAAI,CAAChB,MAAM,CAACK,aAAa,EAAE,MAAM,IAAIY,MAAM,AAAC,sCAA8C,OAATD;QACrF,IAAI,CAAChB,MAAM,CAACK,aAAa,GAAGW;QAC5B,IAAI,IAAI,CAAChB,MAAM,CAACI,KAAK,IAAI,CAAE,CAAA,IAAI,CAACJ,MAAM,CAACC,KAAK,CAACU,MAAM,GAAG,IAAI,CAACX,MAAM,CAACG,YAAY,AAAD,GAAI,OAAO,IAAI,CAACI,UAAU;IACzG;WA3CmBV"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/utils/queue-cb/src/index.ts"],"sourcesContent":["import LinkedArray from './LinkedArray.ts';\n\nexport type DeferCallback = (error?: Error) => void;\nexport type DeferFunction = (calback: DeferCallback) => void;\nexport type AwaitCallback = (error?: Error) => void;\n\n// Threshold for synchronous callbacks before yielding to event loop\n// This prevents stack overflow while minimizing async overhead\nconst SYNC_DEPTH_THRESHOLD = 1000;\n\n// Cross-platform async scheduler (Node 0.8+ compatible)\n// setImmediate is preferred (Node 0.10+), falls back to setTimeout for Node 0.8\nconst scheduleAsync = typeof setImmediate === 'function' ? setImmediate : (fn: () => void) => setTimeout(fn, 0);\n\ninterface QueueState {\n  parallelism: number;\n  tasks: LinkedArray<DeferFunction>;\n  runningCount: number;\n  error: Error | null;\n  awaitCalled: boolean;\n  awaitCallback: AwaitCallback | null;\n  syncDepth: number;\n}\n\nexport default class Queue {\n  private _state: QueueState;\n\n  constructor(parallelism: number = Infinity) {\n    this._state = {\n      parallelism,\n      tasks: new LinkedArray(),\n      runningCount: 0,\n      error: null,\n      awaitCallback: null,\n      awaitCalled: false,\n      syncDepth: 0,\n    };\n    this._callAwait = this._callAwait.bind(this);\n    this._callDefer = this._callDefer.bind(this);\n    this._drainQueue = this._drainQueue.bind(this);\n  }\n\n  private _callAwait() {\n    if (this._state.awaitCalled || !this._state.awaitCallback) return;\n    this._state.awaitCalled = true;\n    return this._state.awaitCallback(this._state.error);\n  }\n\n  private _drainQueue() {\n    // Reset sync depth when we enter from async context\n    this._state.syncDepth = 0;\n    // Process all available tasks up to parallelism limit\n    while (!this._state.error && this._state.tasks.length && this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      this._state.tasks.shift()(this._callDefer);\n    }\n  }\n\n  private _callDefer(err?: Error) {\n    this._state.runningCount--;\n    if (err && !this._state.error) this._state.error = err;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n    if (!this._state.tasks.length) return;\n\n    // Trampoline: yield to event loop periodically to prevent stack overflow\n    this._state.syncDepth++;\n    if (this._state.syncDepth >= SYNC_DEPTH_THRESHOLD) {\n      scheduleAsync(this._drainQueue);\n      return;\n    }\n\n    this._state.runningCount++;\n    this._state.tasks.shift()(this._callDefer);\n  }\n\n  defer(defer: DeferFunction) {\n    if (this._state.error) return;\n    if (this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      defer(this._callDefer);\n    } else this._state.tasks.push(defer);\n  }\n\n  await(callback: AwaitCallback) {\n    if (this._state.awaitCallback) throw new Error(`Awaiting callback was added twice: ${callback}`);\n    this._state.awaitCallback = callback;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n  }\n}\n"],"names":["Queue","SYNC_DEPTH_THRESHOLD","scheduleAsync","setImmediate","fn","setTimeout","parallelism","Infinity","_state","tasks","LinkedArray","runningCount","error","awaitCallback","awaitCalled","syncDepth","_callAwait","bind","_callDefer","_drainQueue","length","shift","err","defer","push","await","callback","Error"],"mappings":";;;;;;;eAwBqBA;;;oEAxBG;;;;;;;;;;;AAMxB,oEAAoE;AACpE,+DAA+D;AAC/D,IAAMC,uBAAuB;AAE7B,wDAAwD;AACxD,gFAAgF;AAChF,IAAMC,gBAAgB,OAAOC,iBAAiB,aAAaA,eAAe,SAACC;WAAmBC,WAAWD,IAAI;;AAY9F,IAAA,AAAMJ,sBAAN;;aAAMA;YAGPM,cAAAA,iEAAsBC;gCAHfP;QAIjB,IAAI,CAACQ,MAAM,GAAG;YACZF,aAAAA;YACAG,OAAO,IAAIC,sBAAW;YACtBC,cAAc;YACdC,OAAO;YACPC,eAAe;YACfC,aAAa;YACbC,WAAW;QACb;QACA,IAAI,CAACC,UAAU,GAAG,IAAI,CAACA,UAAU,CAACC,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACC,UAAU,GAAG,IAAI,CAACA,UAAU,CAACD,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACE,WAAW,GAAG,IAAI,CAACA,WAAW,CAACF,IAAI,CAAC,IAAI;;iBAf5BjB;IAkBnB,OAAQgB,UAIP,GAJD,SAAQA;QACN,IAAI,IAAI,CAACR,MAAM,CAACM,WAAW,IAAI,CAAC,IAAI,CAACN,MAAM,CAACK,aAAa,EAAE;QAC3D,IAAI,CAACL,MAAM,CAACM,WAAW,GAAG;QAC1B,OAAO,IAAI,CAACN,MAAM,CAACK,aAAa,CAAC,IAAI,CAACL,MAAM,CAACI,KAAK;IACpD;IAEA,OAAQO,WAQP,GARD,SAAQA;QACN,oDAAoD;QACpD,IAAI,CAACX,MAAM,CAACO,SAAS,GAAG;QACxB,sDAAsD;QACtD,MAAO,CAAC,IAAI,CAACP,MAAM,CAACI,KAAK,IAAI,IAAI,CAACJ,MAAM,CAACC,KAAK,CAACW,MAAM,IAAI,IAAI,CAACZ,MAAM,CAACG,YAAY,GAAG,IAAI,CAACH,MAAM,CAACF,WAAW,CAAE;YAC3G,IAAI,CAACE,MAAM,CAACG,YAAY;YACxB,IAAI,CAACH,MAAM,CAACC,KAAK,CAACY,KAAK,GAAG,IAAI,CAACH,UAAU;QAC3C;IACF;IAEA,OAAQA,UAeP,GAfD,SAAQA,WAAWI,GAAW;QAC5B,IAAI,CAACd,MAAM,CAACG,YAAY;QACxB,IAAIW,OAAO,CAAC,IAAI,CAACd,MAAM,CAACI,KAAK,EAAE,IAAI,CAACJ,MAAM,CAACI,KAAK,GAAGU;QACnD,IAAI,IAAI,CAACd,MAAM,CAACI,KAAK,IAAI,CAAE,CAAA,IAAI,CAACJ,MAAM,CAACC,KAAK,CAACW,MAAM,GAAG,IAAI,CAACZ,MAAM,CAACG,YAAY,AAAD,GAAI,OAAO,IAAI,CAACK,UAAU;QACvG,IAAI,CAAC,IAAI,CAACR,MAAM,CAACC,KAAK,CAACW,MAAM,EAAE;QAE/B,yEAAyE;QACzE,IAAI,CAACZ,MAAM,CAACO,SAAS;QACrB,IAAI,IAAI,CAACP,MAAM,CAACO,SAAS,IAAId,sBAAsB;YACjDC,cAAc,IAAI,CAACiB,WAAW;YAC9B;QACF;QAEA,IAAI,CAACX,MAAM,CAACG,YAAY;QACxB,IAAI,CAACH,MAAM,CAACC,KAAK,CAACY,KAAK,GAAG,IAAI,CAACH,UAAU;IAC3C;IAEAK,OAAAA,KAMC,GANDA,SAAAA,MAAMA,KAAoB;QACxB,IAAI,IAAI,CAACf,MAAM,CAACI,KAAK,EAAE;QACvB,IAAI,IAAI,CAACJ,MAAM,CAACG,YAAY,GAAG,IAAI,CAACH,MAAM,CAACF,WAAW,EAAE;YACtD,IAAI,CAACE,MAAM,CAACG,YAAY;YACxBY,MAAM,IAAI,CAACL,UAAU;QACvB,OAAO,IAAI,CAACV,MAAM,CAACC,KAAK,CAACe,IAAI,CAACD;IAChC;IAEAE,OAAAA,KAIC,GAJDA,SAAAA,OAAMC,QAAuB;QAC3B,IAAI,IAAI,CAAClB,MAAM,CAACK,aAAa,EAAE,MAAM,IAAIc,MAAM,AAAC,sCAA8C,OAATD;QACrF,IAAI,CAAClB,MAAM,CAACK,aAAa,GAAGa;QAC5B,IAAI,IAAI,CAAClB,MAAM,CAACI,KAAK,IAAI,CAAE,CAAA,IAAI,CAACJ,MAAM,CAACC,KAAK,CAACW,MAAM,GAAG,IAAI,CAACZ,MAAM,CAACG,YAAY,AAAD,GAAI,OAAO,IAAI,CAACK,UAAU;IACzG;WA/DmBhB"}

dist/esm/index.d.ts

@@ -8,2 +8,3 @@ export type DeferCallback = (error?: Error) => void;
     private _callAwait;
+    private _drainQueue;
     private _callDefer;
@@ -10,0 +11,0 @@ defer(defer: DeferFunction): void;

dist/esm/index.js

 import LinkedArray from './LinkedArray.js';
+// Threshold for synchronous callbacks before yielding to event loop
+// This prevents stack overflow while minimizing async overhead
+const SYNC_DEPTH_THRESHOLD = 1000;
+// Cross-platform async scheduler (Node 0.8+ compatible)
+// setImmediate is preferred (Node 0.10+), falls back to setTimeout for Node 0.8
+const scheduleAsync = typeof setImmediate === 'function' ? setImmediate : (fn)=>setTimeout(fn, 0);
 let Queue = class Queue {
@@ -8,2 +14,11 @@ _callAwait() {
     }
+    _drainQueue() {
+        // Reset sync depth when we enter from async context
+        this._state.syncDepth = 0;
+        // Process all available tasks up to parallelism limit
+        while(!this._state.error && this._state.tasks.length && this._state.runningCount < this._state.parallelism){
+            this._state.runningCount++;
+            this._state.tasks.shift()(this._callDefer);
+        }
+    }
     _callDefer(err) {
@@ -14,2 +29,8 @@ this._state.runningCount--;
         if (!this._state.tasks.length) return;
+        // Trampoline: yield to event loop periodically to prevent stack overflow
+        this._state.syncDepth++;
+        if (this._state.syncDepth >= SYNC_DEPTH_THRESHOLD) {
+            scheduleAsync(this._drainQueue);
+            return;
+        }
         this._state.runningCount++;
@@ -37,8 +58,10 @@ this._state.tasks.shift()(this._callDefer);
             awaitCallback: null,
-            awaitCalled: false
+            awaitCalled: false,
+            syncDepth: 0
         };
         this._callAwait = this._callAwait.bind(this);
         this._callDefer = this._callDefer.bind(this);
+        this._drainQueue = this._drainQueue.bind(this);
     }
 };
 export { Queue as default };

dist/esm/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/utils/queue-cb/src/index.ts"],"sourcesContent":["import LinkedArray from './LinkedArray.ts';\n\nexport type DeferCallback = (error?: Error) => void;\nexport type DeferFunction = (calback: DeferCallback) => void;\nexport type AwaitCallback = (error?: Error) => void;\n\ninterface QueueState {\n  parallelism: number;\n  tasks: LinkedArray<DeferFunction>;\n  runningCount: number;\n  error: Error | null;\n  awaitCalled: boolean;\n  awaitCallback: AwaitCallback | null;\n}\n\nexport default class Queue {\n  private _state: QueueState;\n\n  constructor(parallelism: number = Infinity) {\n    this._state = {\n      parallelism,\n      tasks: new LinkedArray(),\n      runningCount: 0,\n      error: null,\n      awaitCallback: null,\n      awaitCalled: false,\n    };\n    this._callAwait = this._callAwait.bind(this);\n    this._callDefer = this._callDefer.bind(this);\n  }\n\n  private _callAwait() {\n    if (this._state.awaitCalled || !this._state.awaitCallback) return;\n    this._state.awaitCalled = true;\n    return this._state.awaitCallback(this._state.error);\n  }\n\n  private _callDefer(err?: Error) {\n    this._state.runningCount--;\n    if (err && !this._state.error) this._state.error = err;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n    if (!this._state.tasks.length) return;\n    this._state.runningCount++;\n    this._state.tasks.shift()(this._callDefer);\n  }\n\n  defer(defer: DeferFunction) {\n    if (this._state.error) return;\n    if (this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      defer(this._callDefer);\n    } else this._state.tasks.push(defer);\n  }\n\n  await(callback: AwaitCallback) {\n    if (this._state.awaitCallback) throw new Error(`Awaiting callback was added twice: ${callback}`);\n    this._state.awaitCallback = callback;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n  }\n}\n"],"names":["LinkedArray","Queue","_callAwait","_state","awaitCalled","awaitCallback","error","_callDefer","err","runningCount","tasks","length","shift","defer","parallelism","push","await","callback","Error","Infinity","bind"],"mappings":"AAAA,OAAOA,iBAAiB,mBAAmB;AAe5B,IAAA,AAAMC,QAAN,MAAMA;IAgBXC,aAAa;QACnB,IAAI,IAAI,CAACC,MAAM,CAACC,WAAW,IAAI,CAAC,IAAI,CAACD,MAAM,CAACE,aAAa,EAAE;QAC3D,IAAI,CAACF,MAAM,CAACC,WAAW,GAAG;QAC1B,OAAO,IAAI,CAACD,MAAM,CAACE,aAAa,CAAC,IAAI,CAACF,MAAM,CAACG,KAAK;IACpD;IAEQC,WAAWC,GAAW,EAAE;QAC9B,IAAI,CAACL,MAAM,CAACM,YAAY;QACxB,IAAID,OAAO,CAAC,IAAI,CAACL,MAAM,CAACG,KAAK,EAAE,IAAI,CAACH,MAAM,CAACG,KAAK,GAAGE;QACnD,IAAI,IAAI,CAACL,MAAM,CAACG,KAAK,IAAI,CAAE,CAAA,IAAI,CAACH,MAAM,CAACO,KAAK,CAACC,MAAM,GAAG,IAAI,CAACR,MAAM,CAACM,YAAY,AAAD,GAAI,OAAO,IAAI,CAACP,UAAU;QACvG,IAAI,CAAC,IAAI,CAACC,MAAM,CAACO,KAAK,CAACC,MAAM,EAAE;QAC/B,IAAI,CAACR,MAAM,CAACM,YAAY;QACxB,IAAI,CAACN,MAAM,CAACO,KAAK,CAACE,KAAK,GAAG,IAAI,CAACL,UAAU;IAC3C;IAEAM,MAAMA,KAAoB,EAAE;QAC1B,IAAI,IAAI,CAACV,MAAM,CAACG,KAAK,EAAE;QACvB,IAAI,IAAI,CAACH,MAAM,CAACM,YAAY,GAAG,IAAI,CAACN,MAAM,CAACW,WAAW,EAAE;YACtD,IAAI,CAACX,MAAM,CAACM,YAAY;YACxBI,MAAM,IAAI,CAACN,UAAU;QACvB,OAAO,IAAI,CAACJ,MAAM,CAACO,KAAK,CAACK,IAAI,CAACF;IAChC;IAEAG,MAAMC,QAAuB,EAAE;QAC7B,IAAI,IAAI,CAACd,MAAM,CAACE,aAAa,EAAE,MAAM,IAAIa,MAAM,CAAC,mCAAmC,EAAED,UAAU;QAC/F,IAAI,CAACd,MAAM,CAACE,aAAa,GAAGY;QAC5B,IAAI,IAAI,CAACd,MAAM,CAACG,KAAK,IAAI,CAAE,CAAA,IAAI,CAACH,MAAM,CAACO,KAAK,CAACC,MAAM,GAAG,IAAI,CAACR,MAAM,CAACM,YAAY,AAAD,GAAI,OAAO,IAAI,CAACP,UAAU;IACzG;IAxCA,YAAYY,cAAsBK,QAAQ,CAAE;QAC1C,IAAI,CAAChB,MAAM,GAAG;YACZW;YACAJ,OAAO,IAAIV;YACXS,cAAc;YACdH,OAAO;YACPD,eAAe;YACfD,aAAa;QACf;QACA,IAAI,CAACF,UAAU,GAAG,IAAI,CAACA,UAAU,CAACkB,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACb,UAAU,GAAG,IAAI,CAACA,UAAU,CAACa,IAAI,CAAC,IAAI;IAC7C;AA8BF;AA5CA,SAAqBnB,mBA4CpB"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/utils/queue-cb/src/index.ts"],"sourcesContent":["import LinkedArray from './LinkedArray.ts';\n\nexport type DeferCallback = (error?: Error) => void;\nexport type DeferFunction = (calback: DeferCallback) => void;\nexport type AwaitCallback = (error?: Error) => void;\n\n// Threshold for synchronous callbacks before yielding to event loop\n// This prevents stack overflow while minimizing async overhead\nconst SYNC_DEPTH_THRESHOLD = 1000;\n\n// Cross-platform async scheduler (Node 0.8+ compatible)\n// setImmediate is preferred (Node 0.10+), falls back to setTimeout for Node 0.8\nconst scheduleAsync = typeof setImmediate === 'function' ? setImmediate : (fn: () => void) => setTimeout(fn, 0);\n\ninterface QueueState {\n  parallelism: number;\n  tasks: LinkedArray<DeferFunction>;\n  runningCount: number;\n  error: Error | null;\n  awaitCalled: boolean;\n  awaitCallback: AwaitCallback | null;\n  syncDepth: number;\n}\n\nexport default class Queue {\n  private _state: QueueState;\n\n  constructor(parallelism: number = Infinity) {\n    this._state = {\n      parallelism,\n      tasks: new LinkedArray(),\n      runningCount: 0,\n      error: null,\n      awaitCallback: null,\n      awaitCalled: false,\n      syncDepth: 0,\n    };\n    this._callAwait = this._callAwait.bind(this);\n    this._callDefer = this._callDefer.bind(this);\n    this._drainQueue = this._drainQueue.bind(this);\n  }\n\n  private _callAwait() {\n    if (this._state.awaitCalled || !this._state.awaitCallback) return;\n    this._state.awaitCalled = true;\n    return this._state.awaitCallback(this._state.error);\n  }\n\n  private _drainQueue() {\n    // Reset sync depth when we enter from async context\n    this._state.syncDepth = 0;\n    // Process all available tasks up to parallelism limit\n    while (!this._state.error && this._state.tasks.length && this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      this._state.tasks.shift()(this._callDefer);\n    }\n  }\n\n  private _callDefer(err?: Error) {\n    this._state.runningCount--;\n    if (err && !this._state.error) this._state.error = err;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n    if (!this._state.tasks.length) return;\n\n    // Trampoline: yield to event loop periodically to prevent stack overflow\n    this._state.syncDepth++;\n    if (this._state.syncDepth >= SYNC_DEPTH_THRESHOLD) {\n      scheduleAsync(this._drainQueue);\n      return;\n    }\n\n    this._state.runningCount++;\n    this._state.tasks.shift()(this._callDefer);\n  }\n\n  defer(defer: DeferFunction) {\n    if (this._state.error) return;\n    if (this._state.runningCount < this._state.parallelism) {\n      this._state.runningCount++;\n      defer(this._callDefer);\n    } else this._state.tasks.push(defer);\n  }\n\n  await(callback: AwaitCallback) {\n    if (this._state.awaitCallback) throw new Error(`Awaiting callback was added twice: ${callback}`);\n    this._state.awaitCallback = callback;\n    if (this._state.error || !(this._state.tasks.length + this._state.runningCount)) return this._callAwait();\n  }\n}\n"],"names":["LinkedArray","SYNC_DEPTH_THRESHOLD","scheduleAsync","setImmediate","fn","setTimeout","Queue","_callAwait","_state","awaitCalled","awaitCallback","error","_drainQueue","syncDepth","tasks","length","runningCount","parallelism","shift","_callDefer","err","defer","push","await","callback","Error","Infinity","bind"],"mappings":"AAAA,OAAOA,iBAAiB,mBAAmB;AAM3C,oEAAoE;AACpE,+DAA+D;AAC/D,MAAMC,uBAAuB;AAE7B,wDAAwD;AACxD,gFAAgF;AAChF,MAAMC,gBAAgB,OAAOC,iBAAiB,aAAaA,eAAe,CAACC,KAAmBC,WAAWD,IAAI;AAY9F,IAAA,AAAME,QAAN,MAAMA;IAkBXC,aAAa;QACnB,IAAI,IAAI,CAACC,MAAM,CAACC,WAAW,IAAI,CAAC,IAAI,CAACD,MAAM,CAACE,aAAa,EAAE;QAC3D,IAAI,CAACF,MAAM,CAACC,WAAW,GAAG;QAC1B,OAAO,IAAI,CAACD,MAAM,CAACE,aAAa,CAAC,IAAI,CAACF,MAAM,CAACG,KAAK;IACpD;IAEQC,cAAc;QACpB,oDAAoD;QACpD,IAAI,CAACJ,MAAM,CAACK,SAAS,GAAG;QACxB,sDAAsD;QACtD,MAAO,CAAC,IAAI,CAACL,MAAM,CAACG,KAAK,IAAI,IAAI,CAACH,MAAM,CAACM,KAAK,CAACC,MAAM,IAAI,IAAI,CAACP,MAAM,CAACQ,YAAY,GAAG,IAAI,CAACR,MAAM,CAACS,WAAW,CAAE;YAC3G,IAAI,CAACT,MAAM,CAACQ,YAAY;YACxB,IAAI,CAACR,MAAM,CAACM,KAAK,CAACI,KAAK,GAAG,IAAI,CAACC,UAAU;QAC3C;IACF;IAEQA,WAAWC,GAAW,EAAE;QAC9B,IAAI,CAACZ,MAAM,CAACQ,YAAY;QACxB,IAAII,OAAO,CAAC,IAAI,CAACZ,MAAM,CAACG,KAAK,EAAE,IAAI,CAACH,MAAM,CAACG,KAAK,GAAGS;QACnD,IAAI,IAAI,CAACZ,MAAM,CAACG,KAAK,IAAI,CAAE,CAAA,IAAI,CAACH,MAAM,CAACM,KAAK,CAACC,MAAM,GAAG,IAAI,CAACP,MAAM,CAACQ,YAAY,AAAD,GAAI,OAAO,IAAI,CAACT,UAAU;QACvG,IAAI,CAAC,IAAI,CAACC,MAAM,CAACM,KAAK,CAACC,MAAM,EAAE;QAE/B,yEAAyE;QACzE,IAAI,CAACP,MAAM,CAACK,SAAS;QACrB,IAAI,IAAI,CAACL,MAAM,CAACK,SAAS,IAAIZ,sBAAsB;YACjDC,cAAc,IAAI,CAACU,WAAW;YAC9B;QACF;QAEA,IAAI,CAACJ,MAAM,CAACQ,YAAY;QACxB,IAAI,CAACR,MAAM,CAACM,KAAK,CAACI,KAAK,GAAG,IAAI,CAACC,UAAU;IAC3C;IAEAE,MAAMA,KAAoB,EAAE;QAC1B,IAAI,IAAI,CAACb,MAAM,CAACG,KAAK,EAAE;QACvB,IAAI,IAAI,CAACH,MAAM,CAACQ,YAAY,GAAG,IAAI,CAACR,MAAM,CAACS,WAAW,EAAE;YACtD,IAAI,CAACT,MAAM,CAACQ,YAAY;YACxBK,MAAM,IAAI,CAACF,UAAU;QACvB,OAAO,IAAI,CAACX,MAAM,CAACM,KAAK,CAACQ,IAAI,CAACD;IAChC;IAEAE,MAAMC,QAAuB,EAAE;QAC7B,IAAI,IAAI,CAAChB,MAAM,CAACE,aAAa,EAAE,MAAM,IAAIe,MAAM,CAAC,mCAAmC,EAAED,UAAU;QAC/F,IAAI,CAAChB,MAAM,CAACE,aAAa,GAAGc;QAC5B,IAAI,IAAI,CAAChB,MAAM,CAACG,KAAK,IAAI,CAAE,CAAA,IAAI,CAACH,MAAM,CAACM,KAAK,CAACC,MAAM,GAAG,IAAI,CAACP,MAAM,CAACQ,YAAY,AAAD,GAAI,OAAO,IAAI,CAACT,UAAU;IACzG;IA5DA,YAAYU,cAAsBS,QAAQ,CAAE;QAC1C,IAAI,CAAClB,MAAM,GAAG;YACZS;YACAH,OAAO,IAAId;YACXgB,cAAc;YACdL,OAAO;YACPD,eAAe;YACfD,aAAa;YACbI,WAAW;QACb;QACA,IAAI,CAACN,UAAU,GAAG,IAAI,CAACA,UAAU,CAACoB,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACR,UAAU,GAAG,IAAI,CAACA,UAAU,CAACQ,IAAI,CAAC,IAAI;QAC3C,IAAI,CAACf,WAAW,GAAG,IAAI,CAACA,WAAW,CAACe,IAAI,CAAC,IAAI;IAC/C;AAgDF;AAhEA,SAAqBrB,mBAgEpB"}

package.json

 {
   "name": "queue-cb",
-  "version": "1.5.11",
+  "version": "1.6.0",
   "description": "A scalable queue for parallel callbacks",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

30787

25.81%

Lines of code

306

19.53%

No dependency changes