Latest Threat Research:SANDWORM_MODE: Shai-Hulud-Style npm Worm Hijacks CI Workflows and Poisons AI Toolchains.Details →
Socket
Book a DemoInstallSign in
Socket
Book a DemoInstallSign in

stack-base-iterator

Package Overview
Dependencies
Maintainers
1
Versions
89
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

stack-base-iterator - npm Package Compare versions

Comparing version
1.2.18
 to
1.2.19
+6
-6
dist/cjs/index.d.cts
import LinkedList from './LinkedList.js';
import type { DefaultFunction, EachFunction, ForEachOptions, ProcessCallback, StackOptions } from './types.js';
import type { EachFunction, ForEachOptions, ProcessCallback, Processor, StackFunction, StackOptions } from './types.js';
export type * from './types.js';
export default class StackBaseIterator<T> implements AsyncIterator<T> {
protected done: boolean;
protected stack: LinkedList<DefaultFunction>;
protected queued: LinkedList<DefaultFunction>;
protected processors: LinkedList<DefaultFunction>;
protected processing: LinkedList<DefaultFunction>;
protected stack: LinkedList<StackFunction<T>>;
protected processors: LinkedList<Processor>;
protected queued: LinkedList<ProcessCallback>;
protected processing: LinkedList<ProcessCallback>;
protected options: StackOptions;

@@ -15,3 +15,3 @@ protected entries: LinkedList<T>;

isDone(): boolean;
push(item: DefaultFunction): void;
push(fn: StackFunction<T>): void;
next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>>;

@@ -18,0 +18,0 @@ forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean>;

+6
-6
dist/cjs/index.d.ts
import LinkedList from './LinkedList.js';
import type { DefaultFunction, EachFunction, ForEachOptions, ProcessCallback, StackOptions } from './types.js';
import type { EachFunction, ForEachOptions, ProcessCallback, Processor, StackFunction, StackOptions } from './types.js';
export type * from './types.js';
export default class StackBaseIterator<T> implements AsyncIterator<T> {
protected done: boolean;
protected stack: LinkedList<DefaultFunction>;
protected queued: LinkedList<DefaultFunction>;
protected processors: LinkedList<DefaultFunction>;
protected processing: LinkedList<DefaultFunction>;
protected stack: LinkedList<StackFunction<T>>;
protected processors: LinkedList<Processor>;
protected queued: LinkedList<ProcessCallback>;
protected processing: LinkedList<ProcessCallback>;
protected options: StackOptions;

@@ -15,3 +15,3 @@ protected entries: LinkedList<T>;

isDone(): boolean;
push(item: DefaultFunction): void;
push(fn: StackFunction<T>): void;
next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>>;

@@ -18,0 +18,0 @@ forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean>;

+3
-3
dist/cjs/index.js

@@ -111,4 +111,4 @@ "use strict";

this.stack = new _LinkedList.default();
this.processors = new _LinkedList.default();
this.queued = new _LinkedList.default();
this.processors = new _LinkedList.default();
this.processing = new _LinkedList.default();

@@ -121,5 +121,5 @@ this.entries = new _LinkedList.default();

};
_proto.push = function push(item) {
_proto.push = function push(fn) {
if (this.done) return console.log('Attempting to push on a done iterator');
this.stack.push(item);
this.stack.push(fn);
(0, _drainStack.default)(this);

@@ -126,0 +126,0 @@ };

+1
-1
dist/cjs/index.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import once from 'call-once-fn';\nimport LinkedList from './LinkedList.js';\n\nimport createProcesor from './createProcessor.js';\nimport drainStack from './drainStack.js';\nimport processOrQueue from './processOrQueue.js';\n\nimport type { AbstractIterator, DefaultFunction, EachFunction, ForEachOptions, ProcessCallback, ProcessorOptions, StackOptions } from './types.js';\n\nexport type * from './types.js';\nexport default class StackBaseIterator<T> implements AsyncIterator<T> {\n protected done: boolean;\n protected stack: LinkedList<DefaultFunction>;\n protected queued: LinkedList<DefaultFunction>;\n protected processors: LinkedList<DefaultFunction>;\n protected processing: LinkedList<DefaultFunction>;\n\n protected options: StackOptions;\n protected entries: LinkedList<T>;\n protected destroyed: boolean;\n\n constructor(options: StackOptions = {}) {\n this.options = { ...options };\n this.options.error =\n options.error ||\n function defaultError(err) {\n return !!err; // fail on errors\n };\n\n this.done = false;\n this.stack = new LinkedList<DefaultFunction>();\n this.queued = new LinkedList<DefaultFunction>();\n this.processors = new LinkedList<DefaultFunction>();\n this.processing = new LinkedList<DefaultFunction>();\n this.entries = new LinkedList<T>();\n }\n\n isDone() {\n return this.done;\n }\n\n push(item: DefaultFunction) {\n if (this.done) return console.log('Attempting to push on a done iterator');\n this.stack.push(item);\n drainStack<T>(this as unknown as AbstractIterator<T>);\n }\n\n next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>> {\n const callback = value as ProcessCallback;\n if (typeof callback === 'function') return processOrQueue(this as unknown as AbstractIterator<T>, once(callback));\n\n return new Promise((resolve, reject) => {\n this.next((err, result) => (err ? reject(err) : resolve(result)));\n });\n }\n\n forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean> {\n if (typeof fn !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as ProcessCallback;\n options = {};\n }\n\n if (typeof callback === 'function') {\n if (this.done) {\n callback(null, true);\n return;\n }\n options = options || {};\n const processorOptions: ProcessorOptions<T> = {\n each: fn,\n callbacks: options.callbacks || false,\n concurrency: options.concurrency || 1,\n limit: options.limit || Infinity,\n error:\n options.error ||\n function defaultError() {\n return true; // default is exit on error\n },\n total: 0,\n counter: 0,\n stop: () => {\n return this.done || this.queued.length >= this.stack.length;\n },\n };\n\n let processor = createProcesor<T>(this.next.bind(this), processorOptions, (err) => {\n if (!this.destroyed) this.processors.removeValue(processor);\n processor = null;\n options = null;\n const done = !this.stack.length;\n if ((err || done) && !this.done) this.end(err);\n return callback(err, this.done || done);\n });\n this.processors.push(processor);\n processor();\n return;\n }\n\n return new Promise((resolve, reject) =>\n this.forEach(fn, options, (err?: Error, done?: boolean) => {\n err ? reject(err) : resolve(done);\n })\n );\n }\n\n end(err?: Error) {\n if (this.done) return;\n this.done = true;\n while (this.processors.length > 0) this.processors.pop()(err || true);\n while (this.processing.length > 0) err ? this.processing.pop()(err) : this.processing.pop()(null, null);\n while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, null);\n while (this.stack.length > 0) this.stack.pop();\n }\n\n destroy(err?: Error) {\n if (this.destroyed) throw new Error('Already destroyed');\n this.destroyed = true;\n this.end(err);\n }\n}\n\nif (typeof Symbol !== 'undefined' && Symbol.asyncIterator) {\n StackBaseIterator.prototype[Symbol.asyncIterator] = function asyncIterator() {\n const self = this;\n return {\n next: function next() {\n return self.next().then(function nextCallback(value) {\n return Promise.resolve({ value: value, done: value === null });\n });\n },\n destroy: function destroy() {\n self.destroy();\n return Promise.resolve();\n },\n };\n };\n}\n"],"names":["StackBaseIterator","options","error","defaultError","err","done","stack","LinkedList","queued","processors","processing","entries","isDone","push","item","console","log","drainStack","next","value","callback","processOrQueue","once","Promise","resolve","reject","result","forEach","fn","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","total","counter","stop","length","processor","createProcesor","bind","destroyed","removeValue","end","pop","destroy","Symbol","asyncIterator","prototype","self","then","nextCallback"],"mappings":";;;;;;;eAUqBA;;;iEAVJ;iEACM;sEAEI;iEACJ;qEACI;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAKZ,IAAA,AAAMA,kCAAN;;aAAMA;YAWPC,UAAAA,iEAAwB,CAAC;gCAXlBD;QAYjB,IAAI,CAACC,OAAO,GAAG,mBAAKA;QACpB,IAAI,CAACA,OAAO,CAACC,KAAK,GAChBD,QAAQC,KAAK,IACb,SAASC,aAAaC,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACC,IAAI,GAAG;QACZ,IAAI,CAACC,KAAK,GAAG,IAAIC,mBAAU;QAC3B,IAAI,CAACC,MAAM,GAAG,IAAID,mBAAU;QAC5B,IAAI,CAACE,UAAU,GAAG,IAAIF,mBAAU;QAChC,IAAI,CAACG,UAAU,GAAG,IAAIH,mBAAU;QAChC,IAAI,CAACI,OAAO,GAAG,IAAIJ,mBAAU;;iBAxBZP;IA2BnBY,OAAAA,MAEC,GAFDA,SAAAA;QACE,OAAO,IAAI,CAACP,IAAI;IAClB;IAEAQ,OAAAA,IAIC,GAJDA,SAAAA,KAAKC,IAAqB;QACxB,IAAI,IAAI,CAACT,IAAI,EAAE,OAAOU,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACV,KAAK,CAACO,IAAI,CAACC;QAChBG,IAAAA,mBAAU,EAAI,IAAI;IACpB;IAEAC,OAAAA,IAOC,GAPDA,SAAAA;;QAAK,IAAA,IAAA,OAAA,UAAA,QAAA,OAAA,UAAA,OAAA,OAAA,GAAA,OAAA,MAAA;YAAA,KAAA,QAAA,SAAA,CAAA,KAA0B;;YAA1B,yBAAA,UAAIC,QAAJ;QACH,IAAMC,WAAWD;QACjB,IAAI,OAAOC,aAAa,YAAY,OAAOC,IAAAA,uBAAc,EAAC,IAAI,EAAoCC,IAAAA,mBAAI,EAACF;QAEvG,OAAO,IAAIG,QAAQ,SAACC,SAASC;YAC3B,MAAKP,IAAI,CAAC,SAACd,KAAKsB;uBAAYtB,MAAMqB,OAAOrB,OAAOoB,QAAQE;;QAC1D;IACF;IAEAC,OAAAA,OAgDC,GAhDDA,SAAAA,QAAQC,EAAmB,EAAE3B,OAA0C,EAAEmB,QAA0B;;QACjG,IAAI,OAAOQ,OAAO,YAAY,MAAM,IAAIC,MAAM;QAC9C,IAAI,OAAO5B,YAAY,YAAY;YACjCmB,WAAWnB;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOmB,aAAa,YAAY;YAClC,IAAI,IAAI,CAACf,IAAI,EAAE;gBACbe,SAAS,MAAM;gBACf;YACF;YACAnB,UAAUA,WAAW,CAAC;YACtB,IAAM6B,mBAAwC;gBAC5CC,MAAMH;gBACNI,WAAW/B,QAAQ+B,SAAS,IAAI;gBAChCC,aAAahC,QAAQgC,WAAW,IAAI;gBACpCC,OAAOjC,QAAQiC,KAAK,IAAIC;gBACxBjC,OACED,QAAQC,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFiC,OAAO;gBACPC,SAAS;gBACTC,MAAM;oBACJ,OAAO,MAAKjC,IAAI,IAAI,MAAKG,MAAM,CAAC+B,MAAM,IAAI,MAAKjC,KAAK,CAACiC,MAAM;gBAC7D;YACF;YAEA,IAAIC,YAAYC,IAAAA,wBAAc,EAAI,IAAI,CAACvB,IAAI,CAACwB,IAAI,CAAC,IAAI,GAAGZ,kBAAkB,SAAC1B;gBACzE,IAAI,CAAC,MAAKuC,SAAS,EAAE,MAAKlC,UAAU,CAACmC,WAAW,CAACJ;gBACjDA,YAAY;gBACZvC,UAAU;gBACV,IAAMI,OAAO,CAAC,MAAKC,KAAK,CAACiC,MAAM;gBAC/B,IAAI,AAACnC,CAAAA,OAAOC,IAAG,KAAM,CAAC,MAAKA,IAAI,EAAE,MAAKwC,GAAG,CAACzC;gBAC1C,OAAOgB,SAAShB,KAAK,MAAKC,IAAI,IAAIA;YACpC;YACA,IAAI,CAACI,UAAU,CAACI,IAAI,CAAC2B;YACrBA;YACA;QACF;QAEA,OAAO,IAAIjB,QAAQ,SAACC,SAASC;mBAC3B,MAAKE,OAAO,CAACC,IAAI3B,SAAS,SAACG,KAAaC;gBACtCD,MAAMqB,OAAOrB,OAAOoB,QAAQnB;YAC9B;;IAEJ;IAEAwC,OAAAA,GAOC,GAPDA,SAAAA,IAAIzC,GAAW;QACb,IAAI,IAAI,CAACC,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACI,UAAU,CAAC8B,MAAM,GAAG,EAAG,IAAI,CAAC9B,UAAU,CAACqC,GAAG,GAAG1C,OAAO;QAChE,MAAO,IAAI,CAACM,UAAU,CAAC6B,MAAM,GAAG,EAAGnC,MAAM,IAAI,CAACM,UAAU,CAACoC,GAAG,GAAG1C,OAAO,IAAI,CAACM,UAAU,CAACoC,GAAG,GAAG,MAAM;QAClG,MAAO,IAAI,CAACtC,MAAM,CAAC+B,MAAM,GAAG,EAAGnC,MAAM,IAAI,CAACI,MAAM,CAACsC,GAAG,GAAG1C,OAAO,IAAI,CAACI,MAAM,CAACsC,GAAG,GAAG,MAAM;QACtF,MAAO,IAAI,CAACxC,KAAK,CAACiC,MAAM,GAAG,EAAG,IAAI,CAACjC,KAAK,CAACwC,GAAG;IAC9C;IAEAC,OAAAA,OAIC,GAJDA,SAAAA,QAAQ3C,GAAW;QACjB,IAAI,IAAI,CAACuC,SAAS,EAAE,MAAM,IAAId,MAAM;QACpC,IAAI,CAACc,SAAS,GAAG;QACjB,IAAI,CAACE,GAAG,CAACzC;IACX;WA7GmBJ;;AAgHrB,IAAI,OAAOgD,WAAW,eAAeA,OAAOC,aAAa,EAAE;IACzDjD,kBAAkBkD,SAAS,CAACF,OAAOC,aAAa,CAAC,GAAG,SAASA;QAC3D,IAAME,OAAO,IAAI;QACjB,OAAO;YACLjC,MAAM,SAASA;gBACb,OAAOiC,KAAKjC,IAAI,GAAGkC,IAAI,CAAC,SAASC,aAAalC,KAAK;oBACjD,OAAOI,QAAQC,OAAO,CAAC;wBAAEL,OAAOA;wBAAOd,MAAMc,UAAU;oBAAK;gBAC9D;YACF;YACA4B,SAAS,SAASA;gBAChBI,KAAKJ,OAAO;gBACZ,OAAOxB,QAAQC,OAAO;YACxB;QACF;IACF;AACF"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import once from 'call-once-fn';\nimport LinkedList from './LinkedList.js';\n\nimport createProcesor from './createProcessor.js';\nimport drainStack from './drainStack.js';\nimport processOrQueue from './processOrQueue.js';\n\nimport type { AbstractIterator, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackFunction, StackOptions } from './types.js';\n\nexport type * from './types.js';\nexport default class StackBaseIterator<T> implements AsyncIterator<T> {\n protected done: boolean;\n protected stack: LinkedList<StackFunction<T>>;\n protected processors: LinkedList<Processor>;\n protected queued: LinkedList<ProcessCallback>;\n protected processing: LinkedList<ProcessCallback>;\n\n protected options: StackOptions;\n protected entries: LinkedList<T>;\n protected destroyed: boolean;\n\n constructor(options: StackOptions = {}) {\n this.options = { ...options };\n this.options.error =\n options.error ||\n function defaultError(err) {\n return !!err; // fail on errors\n };\n\n this.done = false;\n this.stack = new LinkedList<StackFunction<T>>();\n this.processors = new LinkedList<Processor>();\n this.queued = new LinkedList<ProcessCallback>();\n this.processing = new LinkedList<ProcessCallback>();\n this.entries = new LinkedList<T>();\n }\n\n isDone() {\n return this.done;\n }\n\n push(fn: StackFunction<T>) {\n if (this.done) return console.log('Attempting to push on a done iterator');\n this.stack.push(fn);\n drainStack<T>(this as unknown as AbstractIterator<T>);\n }\n\n next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>> {\n const callback = value as ProcessCallback;\n if (typeof callback === 'function') return processOrQueue(this as unknown as AbstractIterator<T>, once(callback));\n\n return new Promise((resolve, reject) => {\n this.next((err, result) => (err ? reject(err) : resolve(result)));\n });\n }\n\n forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean> {\n if (typeof fn !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as ProcessCallback;\n options = {};\n }\n\n if (typeof callback === 'function') {\n if (this.done) {\n callback(null, true);\n return;\n }\n options = options || {};\n const processorOptions: ProcessorOptions<T> = {\n each: fn,\n callbacks: options.callbacks || false,\n concurrency: options.concurrency || 1,\n limit: options.limit || Infinity,\n error:\n options.error ||\n function defaultError() {\n return true; // default is exit on error\n },\n total: 0,\n counter: 0,\n stop: () => {\n return this.done || this.queued.length >= this.stack.length;\n },\n };\n\n let processor = createProcesor<T>(this.next.bind(this), processorOptions, (err) => {\n if (!this.destroyed) this.processors.removeValue(processor);\n processor = null;\n options = null;\n const done = !this.stack.length;\n if ((err || done) && !this.done) this.end(err);\n return callback(err, this.done || done);\n });\n this.processors.push(processor);\n processor();\n return;\n }\n\n return new Promise((resolve, reject) =>\n this.forEach(fn, options, (err?: Error, done?: boolean) => {\n err ? reject(err) : resolve(done);\n })\n );\n }\n\n end(err?: Error) {\n if (this.done) return;\n this.done = true;\n while (this.processors.length > 0) this.processors.pop()(err || true);\n while (this.processing.length > 0) err ? this.processing.pop()(err) : this.processing.pop()(null, null);\n while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, null);\n while (this.stack.length > 0) this.stack.pop();\n }\n\n destroy(err?: Error) {\n if (this.destroyed) throw new Error('Already destroyed');\n this.destroyed = true;\n this.end(err);\n }\n}\n\nif (typeof Symbol !== 'undefined' && Symbol.asyncIterator) {\n StackBaseIterator.prototype[Symbol.asyncIterator] = function asyncIterator() {\n const self = this;\n return {\n next: function next() {\n return self.next().then(function nextCallback(value) {\n return Promise.resolve({ value: value, done: value === null });\n });\n },\n destroy: function destroy() {\n self.destroy();\n return Promise.resolve();\n },\n };\n };\n}\n"],"names":["StackBaseIterator","options","error","defaultError","err","done","stack","LinkedList","processors","queued","processing","entries","isDone","push","fn","console","log","drainStack","next","value","callback","processOrQueue","once","Promise","resolve","reject","result","forEach","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","total","counter","stop","length","processor","createProcesor","bind","destroyed","removeValue","end","pop","destroy","Symbol","asyncIterator","prototype","self","then","nextCallback"],"mappings":";;;;;;;eAUqBA;;;iEAVJ;iEACM;sEAEI;iEACJ;qEACI;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAKZ,IAAA,AAAMA,kCAAN;;aAAMA;YAWPC,UAAAA,iEAAwB,CAAC;gCAXlBD;QAYjB,IAAI,CAACC,OAAO,GAAG,mBAAKA;QACpB,IAAI,CAACA,OAAO,CAACC,KAAK,GAChBD,QAAQC,KAAK,IACb,SAASC,aAAaC,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACC,IAAI,GAAG;QACZ,IAAI,CAACC,KAAK,GAAG,IAAIC,mBAAU;QAC3B,IAAI,CAACC,UAAU,GAAG,IAAID,mBAAU;QAChC,IAAI,CAACE,MAAM,GAAG,IAAIF,mBAAU;QAC5B,IAAI,CAACG,UAAU,GAAG,IAAIH,mBAAU;QAChC,IAAI,CAACI,OAAO,GAAG,IAAIJ,mBAAU;;iBAxBZP;IA2BnBY,OAAAA,MAEC,GAFDA,SAAAA;QACE,OAAO,IAAI,CAACP,IAAI;IAClB;IAEAQ,OAAAA,IAIC,GAJDA,SAAAA,KAAKC,EAAoB;QACvB,IAAI,IAAI,CAACT,IAAI,EAAE,OAAOU,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACV,KAAK,CAACO,IAAI,CAACC;QAChBG,IAAAA,mBAAU,EAAI,IAAI;IACpB;IAEAC,OAAAA,IAOC,GAPDA,SAAAA;;QAAK,IAAA,IAAA,OAAA,UAAA,QAAA,OAAA,UAAA,OAAA,OAAA,GAAA,OAAA,MAAA;YAAA,KAAA,QAAA,SAAA,CAAA,KAA0B;;YAA1B,yBAAA,UAAIC,QAAJ;QACH,IAAMC,WAAWD;QACjB,IAAI,OAAOC,aAAa,YAAY,OAAOC,IAAAA,uBAAc,EAAC,IAAI,EAAoCC,IAAAA,mBAAI,EAACF;QAEvG,OAAO,IAAIG,QAAQ,SAACC,SAASC;YAC3B,MAAKP,IAAI,CAAC,SAACd,KAAKsB;uBAAYtB,MAAMqB,OAAOrB,OAAOoB,QAAQE;;QAC1D;IACF;IAEAC,OAAAA,OAgDC,GAhDDA,SAAAA,QAAQb,EAAmB,EAAEb,OAA0C,EAAEmB,QAA0B;;QACjG,IAAI,OAAON,OAAO,YAAY,MAAM,IAAIc,MAAM;QAC9C,IAAI,OAAO3B,YAAY,YAAY;YACjCmB,WAAWnB;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOmB,aAAa,YAAY;YAClC,IAAI,IAAI,CAACf,IAAI,EAAE;gBACbe,SAAS,MAAM;gBACf;YACF;YACAnB,UAAUA,WAAW,CAAC;YACtB,IAAM4B,mBAAwC;gBAC5CC,MAAMhB;gBACNiB,WAAW9B,QAAQ8B,SAAS,IAAI;gBAChCC,aAAa/B,QAAQ+B,WAAW,IAAI;gBACpCC,OAAOhC,QAAQgC,KAAK,IAAIC;gBACxBhC,OACED,QAAQC,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFgC,OAAO;gBACPC,SAAS;gBACTC,MAAM;oBACJ,OAAO,MAAKhC,IAAI,IAAI,MAAKI,MAAM,CAAC6B,MAAM,IAAI,MAAKhC,KAAK,CAACgC,MAAM;gBAC7D;YACF;YAEA,IAAIC,YAAYC,IAAAA,wBAAc,EAAI,IAAI,CAACtB,IAAI,CAACuB,IAAI,CAAC,IAAI,GAAGZ,kBAAkB,SAACzB;gBACzE,IAAI,CAAC,MAAKsC,SAAS,EAAE,MAAKlC,UAAU,CAACmC,WAAW,CAACJ;gBACjDA,YAAY;gBACZtC,UAAU;gBACV,IAAMI,OAAO,CAAC,MAAKC,KAAK,CAACgC,MAAM;gBAC/B,IAAI,AAAClC,CAAAA,OAAOC,IAAG,KAAM,CAAC,MAAKA,IAAI,EAAE,MAAKuC,GAAG,CAACxC;gBAC1C,OAAOgB,SAAShB,KAAK,MAAKC,IAAI,IAAIA;YACpC;YACA,IAAI,CAACG,UAAU,CAACK,IAAI,CAAC0B;YACrBA;YACA;QACF;QAEA,OAAO,IAAIhB,QAAQ,SAACC,SAASC;mBAC3B,MAAKE,OAAO,CAACb,IAAIb,SAAS,SAACG,KAAaC;gBACtCD,MAAMqB,OAAOrB,OAAOoB,QAAQnB;YAC9B;;IAEJ;IAEAuC,OAAAA,GAOC,GAPDA,SAAAA,IAAIxC,GAAW;QACb,IAAI,IAAI,CAACC,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACG,UAAU,CAAC8B,MAAM,GAAG,EAAG,IAAI,CAAC9B,UAAU,CAACqC,GAAG,GAAGzC,OAAO;QAChE,MAAO,IAAI,CAACM,UAAU,CAAC4B,MAAM,GAAG,EAAGlC,MAAM,IAAI,CAACM,UAAU,CAACmC,GAAG,GAAGzC,OAAO,IAAI,CAACM,UAAU,CAACmC,GAAG,GAAG,MAAM;QAClG,MAAO,IAAI,CAACpC,MAAM,CAAC6B,MAAM,GAAG,EAAGlC,MAAM,IAAI,CAACK,MAAM,CAACoC,GAAG,GAAGzC,OAAO,IAAI,CAACK,MAAM,CAACoC,GAAG,GAAG,MAAM;QACtF,MAAO,IAAI,CAACvC,KAAK,CAACgC,MAAM,GAAG,EAAG,IAAI,CAAChC,KAAK,CAACuC,GAAG;IAC9C;IAEAC,OAAAA,OAIC,GAJDA,SAAAA,QAAQ1C,GAAW;QACjB,IAAI,IAAI,CAACsC,SAAS,EAAE,MAAM,IAAId,MAAM;QACpC,IAAI,CAACc,SAAS,GAAG;QACjB,IAAI,CAACE,GAAG,CAACxC;IACX;WA7GmBJ;;AAgHrB,IAAI,OAAO+C,WAAW,eAAeA,OAAOC,aAAa,EAAE;IACzDhD,kBAAkBiD,SAAS,CAACF,OAAOC,aAAa,CAAC,GAAG,SAASA;QAC3D,IAAME,OAAO,IAAI;QACjB,OAAO;YACLhC,MAAM,SAASA;gBACb,OAAOgC,KAAKhC,IAAI,GAAGiC,IAAI,CAAC,SAASC,aAAajC,KAAK;oBACjD,OAAOI,QAAQC,OAAO,CAAC;wBAAEL,OAAOA;wBAAOd,MAAMc,UAAU;oBAAK;gBAC9D;YACF;YACA2B,SAAS,SAASA;gBAChBI,KAAKJ,OAAO;gBACZ,OAAOvB,QAAQC,OAAO;YACxB;QACF;IACF;AACF"}
+1
-1
dist/cjs/processOrQueue.js

@@ -31,3 +31,3 @@ "use strict";

iterator.processing.push(callback);
next(iterator, function nextCallback(err, result) {
next(iterator, function(err, result) {
// break call stack

@@ -34,0 +34,0 @@ (0, _asap.default)(function() {

+1
-1
dist/cjs/processOrQueue.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/processOrQueue.ts"],"sourcesContent":["import compat from 'async-compat';\n\nimport asap from 'asap';\n\nimport type { AbstractIterator, EachCallback } from './types.js';\n\nexport default function processOrQueue<T>(iterator: AbstractIterator<T>, callback: EachCallback): undefined {\n if (iterator.done) {\n callback(null, null);\n return;\n }\n\n // nothing to process so queue\n if (!iterator.stack.length) {\n iterator.queued.unshift(callback);\n return;\n }\n\n // process next\n const next = iterator.stack.pop();\n iterator.processing.push(callback);\n next(iterator, function nextCallback(err: Error, result: T) {\n // break call stack\n asap(() => {\n // done is based on stack being empty and not error state as the user may choose to skip the error\n iterator.processing.removeValue(callback);\n if (iterator.done) return callback(null, null); // early exit\n if (err && compat.defaultValue(iterator.options.error(err), true)) err = null; // skip error\n\n const done = iterator.stack.length <= 0 && iterator.processing.length <= 0;\n !done && !err && !result ? processOrQueue(iterator, callback) : callback(err, result || null);\n if (done && !iterator.done) iterator.end(); // end\n });\n });\n}\n"],"names":["processOrQueue","iterator","callback","done","stack","length","queued","unshift","next","pop","processing","push","nextCallback","err","result","asap","removeValue","compat","defaultValue","options","error","end"],"mappings":";;;;+BAMA;;;eAAwBA;;;kEANL;2DAEF;;;;;;AAIF,SAASA,eAAkBC,QAA6B,EAAEC,QAAsB;IAC7F,IAAID,SAASE,IAAI,EAAE;QACjBD,SAAS,MAAM;QACf;IACF;IAEA,8BAA8B;IAC9B,IAAI,CAACD,SAASG,KAAK,CAACC,MAAM,EAAE;QAC1BJ,SAASK,MAAM,CAACC,OAAO,CAACL;QACxB;IACF;IAEA,eAAe;IACf,IAAMM,OAAOP,SAASG,KAAK,CAACK,GAAG;IAC/BR,SAASS,UAAU,CAACC,IAAI,CAACT;IACzBM,KAAKP,UAAU,SAASW,aAAaC,GAAU,EAAEC,MAAS;QACxD,mBAAmB;QACnBC,IAAAA,aAAI,EAAC;YACH,kGAAkG;YAClGd,SAASS,UAAU,CAACM,WAAW,CAACd;YAChC,IAAID,SAASE,IAAI,EAAE,OAAOD,SAAS,MAAM,OAAO,aAAa;YAC7D,IAAIW,OAAOI,oBAAM,CAACC,YAAY,CAACjB,SAASkB,OAAO,CAACC,KAAK,CAACP,MAAM,OAAOA,MAAM,MAAM,aAAa;YAE5F,IAAMV,OAAOF,SAASG,KAAK,CAACC,MAAM,IAAI,KAAKJ,SAASS,UAAU,CAACL,MAAM,IAAI;YACzE,CAACF,QAAQ,CAACU,OAAO,CAACC,SAASd,eAAeC,UAAUC,YAAYA,SAASW,KAAKC,UAAU;YACxF,IAAIX,QAAQ,CAACF,SAASE,IAAI,EAAEF,SAASoB,GAAG,IAAI,MAAM;QACpD;IACF;AACF"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/processOrQueue.ts"],"sourcesContent":["import compat from 'async-compat';\n\nimport asap from 'asap';\n\nimport type { AbstractIterator, EachCallback } from './types.js';\n\nexport default function processOrQueue<T>(iterator: AbstractIterator<T>, callback: EachCallback): undefined {\n if (iterator.done) {\n callback(null, null);\n return;\n }\n\n // nothing to process so queue\n if (!iterator.stack.length) {\n iterator.queued.unshift(callback);\n return;\n }\n\n // process next\n const next = iterator.stack.pop();\n iterator.processing.push(callback);\n next(iterator, (err?: Error, result?: T) => {\n // break call stack\n asap(() => {\n // done is based on stack being empty and not error state as the user may choose to skip the error\n iterator.processing.removeValue(callback);\n if (iterator.done) return callback(null, null); // early exit\n if (err && compat.defaultValue(iterator.options.error(err), true)) err = null; // skip error\n\n const done = iterator.stack.length <= 0 && iterator.processing.length <= 0;\n !done && !err && !result ? processOrQueue<T>(iterator, callback) : callback(err, result || null);\n if (done && !iterator.done) iterator.end(); // end\n });\n });\n}\n"],"names":["processOrQueue","iterator","callback","done","stack","length","queued","unshift","next","pop","processing","push","err","result","asap","removeValue","compat","defaultValue","options","error","end"],"mappings":";;;;+BAMA;;;eAAwBA;;;kEANL;2DAEF;;;;;;AAIF,SAASA,eAAkBC,QAA6B,EAAEC,QAAsB;IAC7F,IAAID,SAASE,IAAI,EAAE;QACjBD,SAAS,MAAM;QACf;IACF;IAEA,8BAA8B;IAC9B,IAAI,CAACD,SAASG,KAAK,CAACC,MAAM,EAAE;QAC1BJ,SAASK,MAAM,CAACC,OAAO,CAACL;QACxB;IACF;IAEA,eAAe;IACf,IAAMM,OAAOP,SAASG,KAAK,CAACK,GAAG;IAC/BR,SAASS,UAAU,CAACC,IAAI,CAACT;IACzBM,KAAKP,UAAU,SAACW,KAAaC;QAC3B,mBAAmB;QACnBC,IAAAA,aAAI,EAAC;YACH,kGAAkG;YAClGb,SAASS,UAAU,CAACK,WAAW,CAACb;YAChC,IAAID,SAASE,IAAI,EAAE,OAAOD,SAAS,MAAM,OAAO,aAAa;YAC7D,IAAIU,OAAOI,oBAAM,CAACC,YAAY,CAAChB,SAASiB,OAAO,CAACC,KAAK,CAACP,MAAM,OAAOA,MAAM,MAAM,aAAa;YAE5F,IAAMT,OAAOF,SAASG,KAAK,CAACC,MAAM,IAAI,KAAKJ,SAASS,UAAU,CAACL,MAAM,IAAI;YACzE,CAACF,QAAQ,CAACS,OAAO,CAACC,SAASb,eAAkBC,UAAUC,YAAYA,SAASU,KAAKC,UAAU;YAC3F,IAAIV,QAAQ,CAACF,SAASE,IAAI,EAAEF,SAASmB,GAAG,IAAI,MAAM;QACpD;IACF;AACF"}
+6
-6
dist/cjs/types.d.cts
import type LinkedList from './LinkedList.js';
export { default as LinkedList } from './LinkedList.js';
export type DefaultFunction = (arg1?: unknown, arg2?: unknown) => void;
export type ProcessCallback = (error?: Error, done?: boolean) => void;

@@ -28,10 +27,11 @@ export type Processor = (doneOrError?: Error | boolean) => void;

}
export interface AbstractIterator<_T> {
export type StackFunction<T> = (iterator: AbstractIterator<T>, callback: EachCallback) => void;
export interface AbstractIterator<T> {
done: boolean;
stack: LinkedList<DefaultFunction>;
queued: LinkedList<DefaultFunction>;
processors: LinkedList<DefaultFunction>;
processing: LinkedList<DefaultFunction>;
stack: LinkedList<StackFunction<T>>;
processors: LinkedList<Processor>;
queued: LinkedList<ProcessCallback>;
processing: LinkedList<ProcessCallback>;
options: StackOptions;
end: () => undefined;
}
+6
-6
dist/cjs/types.d.ts
import type LinkedList from './LinkedList.js';
export { default as LinkedList } from './LinkedList.js';
export type DefaultFunction = (arg1?: unknown, arg2?: unknown) => void;
export type ProcessCallback = (error?: Error, done?: boolean) => void;

@@ -28,10 +27,11 @@ export type Processor = (doneOrError?: Error | boolean) => void;

}
export interface AbstractIterator<_T> {
export type StackFunction<T> = (iterator: AbstractIterator<T>, callback: EachCallback) => void;
export interface AbstractIterator<T> {
done: boolean;
stack: LinkedList<DefaultFunction>;
queued: LinkedList<DefaultFunction>;
processors: LinkedList<DefaultFunction>;
processing: LinkedList<DefaultFunction>;
stack: LinkedList<StackFunction<T>>;
processors: LinkedList<Processor>;
queued: LinkedList<ProcessCallback>;
processing: LinkedList<ProcessCallback>;
options: StackOptions;
end: () => undefined;
}
+1
-1
dist/cjs/types.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/types.ts"],"sourcesContent":["import type LinkedList from './LinkedList.js';\n\nexport { default as LinkedList } from './LinkedList.js';\nexport type DefaultFunction = (arg1?: unknown, arg2?: unknown) => void;\n\nexport type ProcessCallback = (error?: Error, done?: boolean) => void;\nexport type Processor = (doneOrError?: Error | boolean) => void;\n\nexport type EachCallback = (error?: Error, value?: unknown) => void;\nexport type EachFunctionCallback<T> = (value: T, callback: EachCallback) => undefined;\nexport type EachFunctionPromise<T> = (value: T) => Promise<unknown>;\nexport type EachFunction<T> = EachFunctionCallback<T> | EachFunctionPromise<T>;\n\nexport type Next = (value: EachCallback) => void;\n\nexport interface StackOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n}\n\nexport interface ForEachOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n callbacks?: boolean;\n concurrency?: number;\n limit?: number;\n}\n\nexport interface ProcessorOptions<T> extends ForEachOptions {\n each: EachFunction<T>;\n counter: number;\n total: number;\n stop: (count?: number) => boolean;\n done?: boolean;\n err?: Error;\n}\n\nexport interface AbstractIterator<_T> {\n done: boolean;\n stack: LinkedList<DefaultFunction>;\n queued: LinkedList<DefaultFunction>;\n processors: LinkedList<DefaultFunction>;\n processing: LinkedList<DefaultFunction>;\n options: StackOptions;\n end: () => undefined;\n}\n"],"names":["LinkedList"],"mappings":";;;;+BAEoBA;;;eAAAA,mBAAU;;;iEAAQ"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/types.ts"],"sourcesContent":["import type LinkedList from './LinkedList.js';\n\nexport { default as LinkedList } from './LinkedList.js';\n\nexport type ProcessCallback = (error?: Error, done?: boolean) => void;\nexport type Processor = (doneOrError?: Error | boolean) => void;\n\nexport type EachCallback = (error?: Error, value?: unknown) => void;\nexport type EachFunctionCallback<T> = (value: T, callback: EachCallback) => undefined;\nexport type EachFunctionPromise<T> = (value: T) => Promise<unknown>;\nexport type EachFunction<T> = EachFunctionCallback<T> | EachFunctionPromise<T>;\n\nexport type Next = (value: EachCallback) => void;\n\nexport interface StackOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n}\n\nexport interface ForEachOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n callbacks?: boolean;\n concurrency?: number;\n limit?: number;\n}\n\nexport interface ProcessorOptions<T> extends ForEachOptions {\n each: EachFunction<T>;\n counter: number;\n total: number;\n stop: (count?: number) => boolean;\n done?: boolean;\n err?: Error;\n}\n\nexport type StackFunction<T> = (iterator: AbstractIterator<T>, callback: EachCallback) => void;\n\nexport interface AbstractIterator<T> {\n done: boolean;\n stack: LinkedList<StackFunction<T>>;\n processors: LinkedList<Processor>;\n queued: LinkedList<ProcessCallback>;\n processing: LinkedList<ProcessCallback>;\n options: StackOptions;\n end: () => undefined;\n}\n"],"names":["LinkedList"],"mappings":";;;;+BAEoBA;;;eAAAA,mBAAU;;;iEAAQ"}
+6
-6
dist/esm/index.d.ts
import LinkedList from './LinkedList.js';
import type { DefaultFunction, EachFunction, ForEachOptions, ProcessCallback, StackOptions } from './types.js';
import type { EachFunction, ForEachOptions, ProcessCallback, Processor, StackFunction, StackOptions } from './types.js';
export type * from './types.js';
export default class StackBaseIterator<T> implements AsyncIterator<T> {
protected done: boolean;
protected stack: LinkedList<DefaultFunction>;
protected queued: LinkedList<DefaultFunction>;
protected processors: LinkedList<DefaultFunction>;
protected processing: LinkedList<DefaultFunction>;
protected stack: LinkedList<StackFunction<T>>;
protected processors: LinkedList<Processor>;
protected queued: LinkedList<ProcessCallback>;
protected processing: LinkedList<ProcessCallback>;
protected options: StackOptions;

@@ -15,3 +15,3 @@ protected entries: LinkedList<T>;

isDone(): boolean;
push(item: DefaultFunction): void;
push(fn: StackFunction<T>): void;
next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>>;

@@ -18,0 +18,0 @@ forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean>;

+3
-3
dist/esm/index.js

@@ -10,5 +10,5 @@ import once from 'call-once-fn';

}
push(item) {
push(fn) {
if (this.done) return console.log('Attempting to push on a done iterator');
this.stack.push(item);
this.stack.push(fn);
drainStack(this);

@@ -87,4 +87,4 @@ }

this.stack = new LinkedList();
this.processors = new LinkedList();
this.queued = new LinkedList();
this.processors = new LinkedList();
this.processing = new LinkedList();

@@ -91,0 +91,0 @@ this.entries = new LinkedList();

+1
-1
dist/esm/index.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import once from 'call-once-fn';\nimport LinkedList from './LinkedList.js';\n\nimport createProcesor from './createProcessor.js';\nimport drainStack from './drainStack.js';\nimport processOrQueue from './processOrQueue.js';\n\nimport type { AbstractIterator, DefaultFunction, EachFunction, ForEachOptions, ProcessCallback, ProcessorOptions, StackOptions } from './types.js';\n\nexport type * from './types.js';\nexport default class StackBaseIterator<T> implements AsyncIterator<T> {\n protected done: boolean;\n protected stack: LinkedList<DefaultFunction>;\n protected queued: LinkedList<DefaultFunction>;\n protected processors: LinkedList<DefaultFunction>;\n protected processing: LinkedList<DefaultFunction>;\n\n protected options: StackOptions;\n protected entries: LinkedList<T>;\n protected destroyed: boolean;\n\n constructor(options: StackOptions = {}) {\n this.options = { ...options };\n this.options.error =\n options.error ||\n function defaultError(err) {\n return !!err; // fail on errors\n };\n\n this.done = false;\n this.stack = new LinkedList<DefaultFunction>();\n this.queued = new LinkedList<DefaultFunction>();\n this.processors = new LinkedList<DefaultFunction>();\n this.processing = new LinkedList<DefaultFunction>();\n this.entries = new LinkedList<T>();\n }\n\n isDone() {\n return this.done;\n }\n\n push(item: DefaultFunction) {\n if (this.done) return console.log('Attempting to push on a done iterator');\n this.stack.push(item);\n drainStack<T>(this as unknown as AbstractIterator<T>);\n }\n\n next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>> {\n const callback = value as ProcessCallback;\n if (typeof callback === 'function') return processOrQueue(this as unknown as AbstractIterator<T>, once(callback));\n\n return new Promise((resolve, reject) => {\n this.next((err, result) => (err ? reject(err) : resolve(result)));\n });\n }\n\n forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean> {\n if (typeof fn !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as ProcessCallback;\n options = {};\n }\n\n if (typeof callback === 'function') {\n if (this.done) {\n callback(null, true);\n return;\n }\n options = options || {};\n const processorOptions: ProcessorOptions<T> = {\n each: fn,\n callbacks: options.callbacks || false,\n concurrency: options.concurrency || 1,\n limit: options.limit || Infinity,\n error:\n options.error ||\n function defaultError() {\n return true; // default is exit on error\n },\n total: 0,\n counter: 0,\n stop: () => {\n return this.done || this.queued.length >= this.stack.length;\n },\n };\n\n let processor = createProcesor<T>(this.next.bind(this), processorOptions, (err) => {\n if (!this.destroyed) this.processors.removeValue(processor);\n processor = null;\n options = null;\n const done = !this.stack.length;\n if ((err || done) && !this.done) this.end(err);\n return callback(err, this.done || done);\n });\n this.processors.push(processor);\n processor();\n return;\n }\n\n return new Promise((resolve, reject) =>\n this.forEach(fn, options, (err?: Error, done?: boolean) => {\n err ? reject(err) : resolve(done);\n })\n );\n }\n\n end(err?: Error) {\n if (this.done) return;\n this.done = true;\n while (this.processors.length > 0) this.processors.pop()(err || true);\n while (this.processing.length > 0) err ? this.processing.pop()(err) : this.processing.pop()(null, null);\n while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, null);\n while (this.stack.length > 0) this.stack.pop();\n }\n\n destroy(err?: Error) {\n if (this.destroyed) throw new Error('Already destroyed');\n this.destroyed = true;\n this.end(err);\n }\n}\n\nif (typeof Symbol !== 'undefined' && Symbol.asyncIterator) {\n StackBaseIterator.prototype[Symbol.asyncIterator] = function asyncIterator() {\n const self = this;\n return {\n next: function next() {\n return self.next().then(function nextCallback(value) {\n return Promise.resolve({ value: value, done: value === null });\n });\n },\n destroy: function destroy() {\n self.destroy();\n return Promise.resolve();\n },\n };\n };\n}\n"],"names":["once","LinkedList","createProcesor","drainStack","processOrQueue","StackBaseIterator","isDone","done","push","item","console","log","stack","next","value","callback","Promise","resolve","reject","err","result","forEach","fn","options","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","error","defaultError","total","counter","stop","queued","length","processor","bind","destroyed","processors","removeValue","end","pop","processing","destroy","entries","Symbol","asyncIterator","prototype","self","then","nextCallback"],"mappings":"AAAA,OAAOA,UAAU,eAAe;AAChC,OAAOC,gBAAgB,kBAAkB;AAEzC,OAAOC,oBAAoB,uBAAuB;AAClD,OAAOC,gBAAgB,kBAAkB;AACzC,OAAOC,oBAAoB,sBAAsB;AAKlC,IAAA,AAAMC,oBAAN,MAAMA;IA2BnBC,SAAS;QACP,OAAO,IAAI,CAACC,IAAI;IAClB;IAEAC,KAAKC,IAAqB,EAAE;QAC1B,IAAI,IAAI,CAACF,IAAI,EAAE,OAAOG,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACC,KAAK,CAACJ,IAAI,CAACC;QAChBN,WAAc,IAAI;IACpB;IAEAU,KAAK,GAAG,CAACC,MAAM,AAAgB,EAAuC;QACpE,MAAMC,WAAWD;QACjB,IAAI,OAAOC,aAAa,YAAY,OAAOX,eAAe,IAAI,EAAoCJ,KAAKe;QAEvG,OAAO,IAAIC,QAAQ,CAACC,SAASC;YAC3B,IAAI,CAACL,IAAI,CAAC,CAACM,KAAKC,SAAYD,MAAMD,OAAOC,OAAOF,QAAQG;QAC1D;IACF;IAEAC,QAAQC,EAAmB,EAAEC,OAA0C,EAAER,QAA0B,EAAgC;QACjI,IAAI,OAAOO,OAAO,YAAY,MAAM,IAAIE,MAAM;QAC9C,IAAI,OAAOD,YAAY,YAAY;YACjCR,WAAWQ;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOR,aAAa,YAAY;YAClC,IAAI,IAAI,CAACR,IAAI,EAAE;gBACbQ,SAAS,MAAM;gBACf;YACF;YACAQ,UAAUA,WAAW,CAAC;YACtB,MAAME,mBAAwC;gBAC5CC,MAAMJ;gBACNK,WAAWJ,QAAQI,SAAS,IAAI;gBAChCC,aAAaL,QAAQK,WAAW,IAAI;gBACpCC,OAAON,QAAQM,KAAK,IAAIC;gBACxBC,OACER,QAAQQ,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFC,OAAO;gBACPC,SAAS;gBACTC,MAAM;oBACJ,OAAO,IAAI,CAAC5B,IAAI,IAAI,IAAI,CAAC6B,MAAM,CAACC,MAAM,IAAI,IAAI,CAACzB,KAAK,CAACyB,MAAM;gBAC7D;YACF;YAEA,IAAIC,YAAYpC,eAAkB,IAAI,CAACW,IAAI,CAAC0B,IAAI,CAAC,IAAI,GAAGd,kBAAkB,CAACN;gBACzE,IAAI,CAAC,IAAI,CAACqB,SAAS,EAAE,IAAI,CAACC,UAAU,CAACC,WAAW,CAACJ;gBACjDA,YAAY;gBACZf,UAAU;gBACV,MAAMhB,OAAO,CAAC,IAAI,CAACK,KAAK,CAACyB,MAAM;gBAC/B,IAAI,AAAClB,CAAAA,OAAOZ,IAAG,KAAM,CAAC,IAAI,CAACA,IAAI,EAAE,IAAI,CAACoC,GAAG,CAACxB;gBAC1C,OAAOJ,SAASI,KAAK,IAAI,CAACZ,IAAI,IAAIA;YACpC;YACA,IAAI,CAACkC,UAAU,CAACjC,IAAI,CAAC8B;YACrBA;YACA;QACF;QAEA,OAAO,IAAItB,QAAQ,CAACC,SAASC,SAC3B,IAAI,CAACG,OAAO,CAACC,IAAIC,SAAS,CAACJ,KAAaZ;gBACtCY,MAAMD,OAAOC,OAAOF,QAAQV;YAC9B;IAEJ;IAEAoC,IAAIxB,GAAW,EAAE;QACf,IAAI,IAAI,CAACZ,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACkC,UAAU,CAACJ,MAAM,GAAG,EAAG,IAAI,CAACI,UAAU,CAACG,GAAG,GAAGzB,OAAO;QAChE,MAAO,IAAI,CAAC0B,UAAU,CAACR,MAAM,GAAG,EAAGlB,MAAM,IAAI,CAAC0B,UAAU,CAACD,GAAG,GAAGzB,OAAO,IAAI,CAAC0B,UAAU,CAACD,GAAG,GAAG,MAAM;QAClG,MAAO,IAAI,CAACR,MAAM,CAACC,MAAM,GAAG,EAAGlB,MAAM,IAAI,CAACiB,MAAM,CAACQ,GAAG,GAAGzB,OAAO,IAAI,CAACiB,MAAM,CAACQ,GAAG,GAAG,MAAM;QACtF,MAAO,IAAI,CAAChC,KAAK,CAACyB,MAAM,GAAG,EAAG,IAAI,CAACzB,KAAK,CAACgC,GAAG;IAC9C;IAEAE,QAAQ3B,GAAW,EAAE;QACnB,IAAI,IAAI,CAACqB,SAAS,EAAE,MAAM,IAAIhB,MAAM;QACpC,IAAI,CAACgB,SAAS,GAAG;QACjB,IAAI,CAACG,GAAG,CAACxB;IACX;IAlGA,YAAYI,UAAwB,CAAC,CAAC,CAAE;QACtC,IAAI,CAACA,OAAO,GAAG;YAAE,GAAGA,OAAO;QAAC;QAC5B,IAAI,CAACA,OAAO,CAACQ,KAAK,GAChBR,QAAQQ,KAAK,IACb,SAASC,aAAab,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACZ,IAAI,GAAG;QACZ,IAAI,CAACK,KAAK,GAAG,IAAIX;QACjB,IAAI,CAACmC,MAAM,GAAG,IAAInC;QAClB,IAAI,CAACwC,UAAU,GAAG,IAAIxC;QACtB,IAAI,CAAC4C,UAAU,GAAG,IAAI5C;QACtB,IAAI,CAAC8C,OAAO,GAAG,IAAI9C;IACrB;AAqFF;AA9GA,SAAqBI,+BA8GpB;AAED,IAAI,OAAO2C,WAAW,eAAeA,OAAOC,aAAa,EAAE;IACzD5C,kBAAkB6C,SAAS,CAACF,OAAOC,aAAa,CAAC,GAAG,SAASA;QAC3D,MAAME,OAAO,IAAI;QACjB,OAAO;YACLtC,MAAM,SAASA;gBACb,OAAOsC,KAAKtC,IAAI,GAAGuC,IAAI,CAAC,SAASC,aAAavC,KAAK;oBACjD,OAAOE,QAAQC,OAAO,CAAC;wBAAEH,OAAOA;wBAAOP,MAAMO,UAAU;oBAAK;gBAC9D;YACF;YACAgC,SAAS,SAASA;gBAChBK,KAAKL,OAAO;gBACZ,OAAO9B,QAAQC,OAAO;YACxB;QACF;IACF;AACF"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import once from 'call-once-fn';\nimport LinkedList from './LinkedList.js';\n\nimport createProcesor from './createProcessor.js';\nimport drainStack from './drainStack.js';\nimport processOrQueue from './processOrQueue.js';\n\nimport type { AbstractIterator, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackFunction, StackOptions } from './types.js';\n\nexport type * from './types.js';\nexport default class StackBaseIterator<T> implements AsyncIterator<T> {\n protected done: boolean;\n protected stack: LinkedList<StackFunction<T>>;\n protected processors: LinkedList<Processor>;\n protected queued: LinkedList<ProcessCallback>;\n protected processing: LinkedList<ProcessCallback>;\n\n protected options: StackOptions;\n protected entries: LinkedList<T>;\n protected destroyed: boolean;\n\n constructor(options: StackOptions = {}) {\n this.options = { ...options };\n this.options.error =\n options.error ||\n function defaultError(err) {\n return !!err; // fail on errors\n };\n\n this.done = false;\n this.stack = new LinkedList<StackFunction<T>>();\n this.processors = new LinkedList<Processor>();\n this.queued = new LinkedList<ProcessCallback>();\n this.processing = new LinkedList<ProcessCallback>();\n this.entries = new LinkedList<T>();\n }\n\n isDone() {\n return this.done;\n }\n\n push(fn: StackFunction<T>) {\n if (this.done) return console.log('Attempting to push on a done iterator');\n this.stack.push(fn);\n drainStack<T>(this as unknown as AbstractIterator<T>);\n }\n\n next(...[value]: [] | [unknown]): Promise<IteratorResult<T, unknown>> {\n const callback = value as ProcessCallback;\n if (typeof callback === 'function') return processOrQueue(this as unknown as AbstractIterator<T>, once(callback));\n\n return new Promise((resolve, reject) => {\n this.next((err, result) => (err ? reject(err) : resolve(result)));\n });\n }\n\n forEach(fn: EachFunction<T>, options?: ForEachOptions | ProcessCallback, callback?: ProcessCallback): undefined | Promise<boolean> {\n if (typeof fn !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as ProcessCallback;\n options = {};\n }\n\n if (typeof callback === 'function') {\n if (this.done) {\n callback(null, true);\n return;\n }\n options = options || {};\n const processorOptions: ProcessorOptions<T> = {\n each: fn,\n callbacks: options.callbacks || false,\n concurrency: options.concurrency || 1,\n limit: options.limit || Infinity,\n error:\n options.error ||\n function defaultError() {\n return true; // default is exit on error\n },\n total: 0,\n counter: 0,\n stop: () => {\n return this.done || this.queued.length >= this.stack.length;\n },\n };\n\n let processor = createProcesor<T>(this.next.bind(this), processorOptions, (err) => {\n if (!this.destroyed) this.processors.removeValue(processor);\n processor = null;\n options = null;\n const done = !this.stack.length;\n if ((err || done) && !this.done) this.end(err);\n return callback(err, this.done || done);\n });\n this.processors.push(processor);\n processor();\n return;\n }\n\n return new Promise((resolve, reject) =>\n this.forEach(fn, options, (err?: Error, done?: boolean) => {\n err ? reject(err) : resolve(done);\n })\n );\n }\n\n end(err?: Error) {\n if (this.done) return;\n this.done = true;\n while (this.processors.length > 0) this.processors.pop()(err || true);\n while (this.processing.length > 0) err ? this.processing.pop()(err) : this.processing.pop()(null, null);\n while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, null);\n while (this.stack.length > 0) this.stack.pop();\n }\n\n destroy(err?: Error) {\n if (this.destroyed) throw new Error('Already destroyed');\n this.destroyed = true;\n this.end(err);\n }\n}\n\nif (typeof Symbol !== 'undefined' && Symbol.asyncIterator) {\n StackBaseIterator.prototype[Symbol.asyncIterator] = function asyncIterator() {\n const self = this;\n return {\n next: function next() {\n return self.next().then(function nextCallback(value) {\n return Promise.resolve({ value: value, done: value === null });\n });\n },\n destroy: function destroy() {\n self.destroy();\n return Promise.resolve();\n },\n };\n };\n}\n"],"names":["once","LinkedList","createProcesor","drainStack","processOrQueue","StackBaseIterator","isDone","done","push","fn","console","log","stack","next","value","callback","Promise","resolve","reject","err","result","forEach","options","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","error","defaultError","total","counter","stop","queued","length","processor","bind","destroyed","processors","removeValue","end","pop","processing","destroy","entries","Symbol","asyncIterator","prototype","self","then","nextCallback"],"mappings":"AAAA,OAAOA,UAAU,eAAe;AAChC,OAAOC,gBAAgB,kBAAkB;AAEzC,OAAOC,oBAAoB,uBAAuB;AAClD,OAAOC,gBAAgB,kBAAkB;AACzC,OAAOC,oBAAoB,sBAAsB;AAKlC,IAAA,AAAMC,oBAAN,MAAMA;IA2BnBC,SAAS;QACP,OAAO,IAAI,CAACC,IAAI;IAClB;IAEAC,KAAKC,EAAoB,EAAE;QACzB,IAAI,IAAI,CAACF,IAAI,EAAE,OAAOG,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACC,KAAK,CAACJ,IAAI,CAACC;QAChBN,WAAc,IAAI;IACpB;IAEAU,KAAK,GAAG,CAACC,MAAM,AAAgB,EAAuC;QACpE,MAAMC,WAAWD;QACjB,IAAI,OAAOC,aAAa,YAAY,OAAOX,eAAe,IAAI,EAAoCJ,KAAKe;QAEvG,OAAO,IAAIC,QAAQ,CAACC,SAASC;YAC3B,IAAI,CAACL,IAAI,CAAC,CAACM,KAAKC,SAAYD,MAAMD,OAAOC,OAAOF,QAAQG;QAC1D;IACF;IAEAC,QAAQZ,EAAmB,EAAEa,OAA0C,EAAEP,QAA0B,EAAgC;QACjI,IAAI,OAAON,OAAO,YAAY,MAAM,IAAIc,MAAM;QAC9C,IAAI,OAAOD,YAAY,YAAY;YACjCP,WAAWO;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOP,aAAa,YAAY;YAClC,IAAI,IAAI,CAACR,IAAI,EAAE;gBACbQ,SAAS,MAAM;gBACf;YACF;YACAO,UAAUA,WAAW,CAAC;YACtB,MAAME,mBAAwC;gBAC5CC,MAAMhB;gBACNiB,WAAWJ,QAAQI,SAAS,IAAI;gBAChCC,aAAaL,QAAQK,WAAW,IAAI;gBACpCC,OAAON,QAAQM,KAAK,IAAIC;gBACxBC,OACER,QAAQQ,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFC,OAAO;gBACPC,SAAS;gBACTC,MAAM;oBACJ,OAAO,IAAI,CAAC3B,IAAI,IAAI,IAAI,CAAC4B,MAAM,CAACC,MAAM,IAAI,IAAI,CAACxB,KAAK,CAACwB,MAAM;gBAC7D;YACF;YAEA,IAAIC,YAAYnC,eAAkB,IAAI,CAACW,IAAI,CAACyB,IAAI,CAAC,IAAI,GAAGd,kBAAkB,CAACL;gBACzE,IAAI,CAAC,IAAI,CAACoB,SAAS,EAAE,IAAI,CAACC,UAAU,CAACC,WAAW,CAACJ;gBACjDA,YAAY;gBACZf,UAAU;gBACV,MAAMf,OAAO,CAAC,IAAI,CAACK,KAAK,CAACwB,MAAM;gBAC/B,IAAI,AAACjB,CAAAA,OAAOZ,IAAG,KAAM,CAAC,IAAI,CAACA,IAAI,EAAE,IAAI,CAACmC,GAAG,CAACvB;gBAC1C,OAAOJ,SAASI,KAAK,IAAI,CAACZ,IAAI,IAAIA;YACpC;YACA,IAAI,CAACiC,UAAU,CAAChC,IAAI,CAAC6B;YACrBA;YACA;QACF;QAEA,OAAO,IAAIrB,QAAQ,CAACC,SAASC,SAC3B,IAAI,CAACG,OAAO,CAACZ,IAAIa,SAAS,CAACH,KAAaZ;gBACtCY,MAAMD,OAAOC,OAAOF,QAAQV;YAC9B;IAEJ;IAEAmC,IAAIvB,GAAW,EAAE;QACf,IAAI,IAAI,CAACZ,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACiC,UAAU,CAACJ,MAAM,GAAG,EAAG,IAAI,CAACI,UAAU,CAACG,GAAG,GAAGxB,OAAO;QAChE,MAAO,IAAI,CAACyB,UAAU,CAACR,MAAM,GAAG,EAAGjB,MAAM,IAAI,CAACyB,UAAU,CAACD,GAAG,GAAGxB,OAAO,IAAI,CAACyB,UAAU,CAACD,GAAG,GAAG,MAAM;QAClG,MAAO,IAAI,CAACR,MAAM,CAACC,MAAM,GAAG,EAAGjB,MAAM,IAAI,CAACgB,MAAM,CAACQ,GAAG,GAAGxB,OAAO,IAAI,CAACgB,MAAM,CAACQ,GAAG,GAAG,MAAM;QACtF,MAAO,IAAI,CAAC/B,KAAK,CAACwB,MAAM,GAAG,EAAG,IAAI,CAACxB,KAAK,CAAC+B,GAAG;IAC9C;IAEAE,QAAQ1B,GAAW,EAAE;QACnB,IAAI,IAAI,CAACoB,SAAS,EAAE,MAAM,IAAIhB,MAAM;QACpC,IAAI,CAACgB,SAAS,GAAG;QACjB,IAAI,CAACG,GAAG,CAACvB;IACX;IAlGA,YAAYG,UAAwB,CAAC,CAAC,CAAE;QACtC,IAAI,CAACA,OAAO,GAAG;YAAE,GAAGA,OAAO;QAAC;QAC5B,IAAI,CAACA,OAAO,CAACQ,KAAK,GAChBR,QAAQQ,KAAK,IACb,SAASC,aAAaZ,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACZ,IAAI,GAAG;QACZ,IAAI,CAACK,KAAK,GAAG,IAAIX;QACjB,IAAI,CAACuC,UAAU,GAAG,IAAIvC;QACtB,IAAI,CAACkC,MAAM,GAAG,IAAIlC;QAClB,IAAI,CAAC2C,UAAU,GAAG,IAAI3C;QACtB,IAAI,CAAC6C,OAAO,GAAG,IAAI7C;IACrB;AAqFF;AA9GA,SAAqBI,+BA8GpB;AAED,IAAI,OAAO0C,WAAW,eAAeA,OAAOC,aAAa,EAAE;IACzD3C,kBAAkB4C,SAAS,CAACF,OAAOC,aAAa,CAAC,GAAG,SAASA;QAC3D,MAAME,OAAO,IAAI;QACjB,OAAO;YACLrC,MAAM,SAASA;gBACb,OAAOqC,KAAKrC,IAAI,GAAGsC,IAAI,CAAC,SAASC,aAAatC,KAAK;oBACjD,OAAOE,QAAQC,OAAO,CAAC;wBAAEH,OAAOA;wBAAOP,MAAMO,UAAU;oBAAK;gBAC9D;YACF;YACA+B,SAAS,SAASA;gBAChBK,KAAKL,OAAO;gBACZ,OAAO7B,QAAQC,OAAO;YACxB;QACF;IACF;AACF"}
+1
-1
dist/esm/processOrQueue.js

@@ -16,3 +16,3 @@ import compat from 'async-compat';

iterator.processing.push(callback);
next(iterator, function nextCallback(err, result) {
next(iterator, (err, result)=>{
// break call stack

@@ -19,0 +19,0 @@ asap(()=>{

+1
-1
dist/esm/processOrQueue.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/processOrQueue.ts"],"sourcesContent":["import compat from 'async-compat';\n\nimport asap from 'asap';\n\nimport type { AbstractIterator, EachCallback } from './types.js';\n\nexport default function processOrQueue<T>(iterator: AbstractIterator<T>, callback: EachCallback): undefined {\n if (iterator.done) {\n callback(null, null);\n return;\n }\n\n // nothing to process so queue\n if (!iterator.stack.length) {\n iterator.queued.unshift(callback);\n return;\n }\n\n // process next\n const next = iterator.stack.pop();\n iterator.processing.push(callback);\n next(iterator, function nextCallback(err: Error, result: T) {\n // break call stack\n asap(() => {\n // done is based on stack being empty and not error state as the user may choose to skip the error\n iterator.processing.removeValue(callback);\n if (iterator.done) return callback(null, null); // early exit\n if (err && compat.defaultValue(iterator.options.error(err), true)) err = null; // skip error\n\n const done = iterator.stack.length <= 0 && iterator.processing.length <= 0;\n !done && !err && !result ? processOrQueue(iterator, callback) : callback(err, result || null);\n if (done && !iterator.done) iterator.end(); // end\n });\n });\n}\n"],"names":["compat","asap","processOrQueue","iterator","callback","done","stack","length","queued","unshift","next","pop","processing","push","nextCallback","err","result","removeValue","defaultValue","options","error","end"],"mappings":"AAAA,OAAOA,YAAY,eAAe;AAElC,OAAOC,UAAU,OAAO;AAIxB,eAAe,SAASC,eAAkBC,QAA6B,EAAEC,QAAsB;IAC7F,IAAID,SAASE,IAAI,EAAE;QACjBD,SAAS,MAAM;QACf;IACF;IAEA,8BAA8B;IAC9B,IAAI,CAACD,SAASG,KAAK,CAACC,MAAM,EAAE;QAC1BJ,SAASK,MAAM,CAACC,OAAO,CAACL;QACxB;IACF;IAEA,eAAe;IACf,MAAMM,OAAOP,SAASG,KAAK,CAACK,GAAG;IAC/BR,SAASS,UAAU,CAACC,IAAI,CAACT;IACzBM,KAAKP,UAAU,SAASW,aAAaC,GAAU,EAAEC,MAAS;QACxD,mBAAmB;QACnBf,KAAK;YACH,kGAAkG;YAClGE,SAASS,UAAU,CAACK,WAAW,CAACb;YAChC,IAAID,SAASE,IAAI,EAAE,OAAOD,SAAS,MAAM,OAAO,aAAa;YAC7D,IAAIW,OAAOf,OAAOkB,YAAY,CAACf,SAASgB,OAAO,CAACC,KAAK,CAACL,MAAM,OAAOA,MAAM,MAAM,aAAa;YAE5F,MAAMV,OAAOF,SAASG,KAAK,CAACC,MAAM,IAAI,KAAKJ,SAASS,UAAU,CAACL,MAAM,IAAI;YACzE,CAACF,QAAQ,CAACU,OAAO,CAACC,SAASd,eAAeC,UAAUC,YAAYA,SAASW,KAAKC,UAAU;YACxF,IAAIX,QAAQ,CAACF,SAASE,IAAI,EAAEF,SAASkB,GAAG,IAAI,MAAM;QACpD;IACF;AACF"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/processOrQueue.ts"],"sourcesContent":["import compat from 'async-compat';\n\nimport asap from 'asap';\n\nimport type { AbstractIterator, EachCallback } from './types.js';\n\nexport default function processOrQueue<T>(iterator: AbstractIterator<T>, callback: EachCallback): undefined {\n if (iterator.done) {\n callback(null, null);\n return;\n }\n\n // nothing to process so queue\n if (!iterator.stack.length) {\n iterator.queued.unshift(callback);\n return;\n }\n\n // process next\n const next = iterator.stack.pop();\n iterator.processing.push(callback);\n next(iterator, (err?: Error, result?: T) => {\n // break call stack\n asap(() => {\n // done is based on stack being empty and not error state as the user may choose to skip the error\n iterator.processing.removeValue(callback);\n if (iterator.done) return callback(null, null); // early exit\n if (err && compat.defaultValue(iterator.options.error(err), true)) err = null; // skip error\n\n const done = iterator.stack.length <= 0 && iterator.processing.length <= 0;\n !done && !err && !result ? processOrQueue<T>(iterator, callback) : callback(err, result || null);\n if (done && !iterator.done) iterator.end(); // end\n });\n });\n}\n"],"names":["compat","asap","processOrQueue","iterator","callback","done","stack","length","queued","unshift","next","pop","processing","push","err","result","removeValue","defaultValue","options","error","end"],"mappings":"AAAA,OAAOA,YAAY,eAAe;AAElC,OAAOC,UAAU,OAAO;AAIxB,eAAe,SAASC,eAAkBC,QAA6B,EAAEC,QAAsB;IAC7F,IAAID,SAASE,IAAI,EAAE;QACjBD,SAAS,MAAM;QACf;IACF;IAEA,8BAA8B;IAC9B,IAAI,CAACD,SAASG,KAAK,CAACC,MAAM,EAAE;QAC1BJ,SAASK,MAAM,CAACC,OAAO,CAACL;QACxB;IACF;IAEA,eAAe;IACf,MAAMM,OAAOP,SAASG,KAAK,CAACK,GAAG;IAC/BR,SAASS,UAAU,CAACC,IAAI,CAACT;IACzBM,KAAKP,UAAU,CAACW,KAAaC;QAC3B,mBAAmB;QACnBd,KAAK;YACH,kGAAkG;YAClGE,SAASS,UAAU,CAACI,WAAW,CAACZ;YAChC,IAAID,SAASE,IAAI,EAAE,OAAOD,SAAS,MAAM,OAAO,aAAa;YAC7D,IAAIU,OAAOd,OAAOiB,YAAY,CAACd,SAASe,OAAO,CAACC,KAAK,CAACL,MAAM,OAAOA,MAAM,MAAM,aAAa;YAE5F,MAAMT,OAAOF,SAASG,KAAK,CAACC,MAAM,IAAI,KAAKJ,SAASS,UAAU,CAACL,MAAM,IAAI;YACzE,CAACF,QAAQ,CAACS,OAAO,CAACC,SAASb,eAAkBC,UAAUC,YAAYA,SAASU,KAAKC,UAAU;YAC3F,IAAIV,QAAQ,CAACF,SAASE,IAAI,EAAEF,SAASiB,GAAG,IAAI,MAAM;QACpD;IACF;AACF"}
+6
-6
dist/esm/types.d.ts
import type LinkedList from './LinkedList.js';
export { default as LinkedList } from './LinkedList.js';
export type DefaultFunction = (arg1?: unknown, arg2?: unknown) => void;
export type ProcessCallback = (error?: Error, done?: boolean) => void;

@@ -28,10 +27,11 @@ export type Processor = (doneOrError?: Error | boolean) => void;

}
export interface AbstractIterator<_T> {
export type StackFunction<T> = (iterator: AbstractIterator<T>, callback: EachCallback) => void;
export interface AbstractIterator<T> {
done: boolean;
stack: LinkedList<DefaultFunction>;
queued: LinkedList<DefaultFunction>;
processors: LinkedList<DefaultFunction>;
processing: LinkedList<DefaultFunction>;
stack: LinkedList<StackFunction<T>>;
processors: LinkedList<Processor>;
queued: LinkedList<ProcessCallback>;
processing: LinkedList<ProcessCallback>;
options: StackOptions;
end: () => undefined;
}
+1
-1
dist/esm/types.js.map

@@ -1,1 +0,1 @@

{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/types.ts"],"sourcesContent":["import type LinkedList from './LinkedList.js';\n\nexport { default as LinkedList } from './LinkedList.js';\nexport type DefaultFunction = (arg1?: unknown, arg2?: unknown) => void;\n\nexport type ProcessCallback = (error?: Error, done?: boolean) => void;\nexport type Processor = (doneOrError?: Error | boolean) => void;\n\nexport type EachCallback = (error?: Error, value?: unknown) => void;\nexport type EachFunctionCallback<T> = (value: T, callback: EachCallback) => undefined;\nexport type EachFunctionPromise<T> = (value: T) => Promise<unknown>;\nexport type EachFunction<T> = EachFunctionCallback<T> | EachFunctionPromise<T>;\n\nexport type Next = (value: EachCallback) => void;\n\nexport interface StackOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n}\n\nexport interface ForEachOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n callbacks?: boolean;\n concurrency?: number;\n limit?: number;\n}\n\nexport interface ProcessorOptions<T> extends ForEachOptions {\n each: EachFunction<T>;\n counter: number;\n total: number;\n stop: (count?: number) => boolean;\n done?: boolean;\n err?: Error;\n}\n\nexport interface AbstractIterator<_T> {\n done: boolean;\n stack: LinkedList<DefaultFunction>;\n queued: LinkedList<DefaultFunction>;\n processors: LinkedList<DefaultFunction>;\n processing: LinkedList<DefaultFunction>;\n options: StackOptions;\n end: () => undefined;\n}\n"],"names":["default","LinkedList"],"mappings":"AAEA,SAASA,WAAWC,UAAU,QAAQ,kBAAkB"}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/types.ts"],"sourcesContent":["import type LinkedList from './LinkedList.js';\n\nexport { default as LinkedList } from './LinkedList.js';\n\nexport type ProcessCallback = (error?: Error, done?: boolean) => void;\nexport type Processor = (doneOrError?: Error | boolean) => void;\n\nexport type EachCallback = (error?: Error, value?: unknown) => void;\nexport type EachFunctionCallback<T> = (value: T, callback: EachCallback) => undefined;\nexport type EachFunctionPromise<T> = (value: T) => Promise<unknown>;\nexport type EachFunction<T> = EachFunctionCallback<T> | EachFunctionPromise<T>;\n\nexport type Next = (value: EachCallback) => void;\n\nexport interface StackOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n}\n\nexport interface ForEachOptions {\n error?: (err: NodeJS.ErrnoException) => boolean;\n callbacks?: boolean;\n concurrency?: number;\n limit?: number;\n}\n\nexport interface ProcessorOptions<T> extends ForEachOptions {\n each: EachFunction<T>;\n counter: number;\n total: number;\n stop: (count?: number) => boolean;\n done?: boolean;\n err?: Error;\n}\n\nexport type StackFunction<T> = (iterator: AbstractIterator<T>, callback: EachCallback) => void;\n\nexport interface AbstractIterator<T> {\n done: boolean;\n stack: LinkedList<StackFunction<T>>;\n processors: LinkedList<Processor>;\n queued: LinkedList<ProcessCallback>;\n processing: LinkedList<ProcessCallback>;\n options: StackOptions;\n end: () => undefined;\n}\n"],"names":["default","LinkedList"],"mappings":"AAEA,SAASA,WAAWC,UAAU,QAAQ,kBAAkB"}
+1
-1
package.json
{
"name": "stack-base-iterator",
"version": "1.2.18",
"version": "1.2.19",
"description": "Base iterator for values retrieved using a stack of async functions returning values",

@@ -5,0 +5,0 @@ "keywords": [