stack-base-iterator - npm Package Compare versions

Comparing version 2.0.4 to 2.0.5

dist/cjs/index.js

@@ -62,6 +62,7 @@ "use strict";
 }
+var root = typeof window === 'undefined' ? global : window;
 // biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy
-var Symbol = typeof global.Symbol === 'undefined' ? {
+var Symbol = typeof root.Symbol === 'undefined' ? {
     asyncIterator: undefined
-} : global.Symbol;
+} : root.Symbol;
 var StackBaseIterator = /*#__PURE__*/ function() {
@@ -68,0 +69,0 @@ "use strict";

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 compat from 'async-compat';\nimport nextCallback from 'iterator-next-callback';\nimport { createProcessor } from 'maximize-iterator';\nimport Pinkie from 'pinkie-promise';\nimport LinkedList from './LinkedList.ts';\n\nimport type { EachDoneCallback, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackOptions, ValueCallback } from './types.ts';\n\nexport type StackFunction<T, TReturn = unknown, TNext = unknown> = (iterator: StackBaseIterator<T, TReturn, TNext>, callback: ValueCallback<T>) => void;\n\n// biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy\nconst Symbol: SymbolConstructor = typeof global.Symbol === 'undefined' ? ({ asyncIterator: undefined } as unknown as SymbolConstructor) : global.Symbol;\n\nexport { default as LinkedList } from './LinkedList.ts';\nexport type * from './types.ts';\nexport default class StackBaseIterator<T, TReturn = unknown, TNext = unknown> implements AsyncIterableIterator<T, TReturn, TNext> {\n  protected done: boolean;\n  protected stack: StackFunction<T, TReturn, TNext>[];\n  protected queued: ProcessCallback<T>[];\n  protected processors: LinkedList<Processor>;\n  protected processing: LinkedList<ProcessCallback<T>>;\n\n  protected options: StackOptions;\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 = [] as StackFunction<T, TReturn, TNext>[];\n    this.queued = [] as ProcessCallback<T>[];\n    this.processors = new LinkedList<Processor>();\n    this.processing = new LinkedList<ProcessCallback<T>>();\n  }\n\n  isDone() {\n    return this.done;\n  }\n\n  push(fn: StackFunction<T, TReturn, TNext>, ...rest: StackFunction<T, TReturn, TNext>[]) {\n    if (this.done) return console.log('Attempting to push on a done iterator');\n    this.stack.push(fn);\n    !rest.length || rest.forEach((x) => this.stack.push(x));\n    this._pump();\n  }\n\n  next(): Promise<IteratorResult<T, TReturn>> {\n    return new Pinkie((resolve, reject) => {\n      this._processOrQueue((err, result: IteratorResult<T, TReturn>) => {\n        err ? reject(err) : resolve(result);\n      });\n    });\n  }\n\n  [Symbol.asyncIterator](): AsyncIterableIterator<T, TReturn, TNext> {\n    return this;\n  }\n\n  forEach(fn: EachFunction<T>, options?: ForEachOptions | EachDoneCallback, callback?: EachDoneCallback): undefined | Promise<boolean> {\n    if (typeof fn !== 'function') throw new Error('Missing each function');\n    if (typeof options === 'function') {\n      callback = options as EachDoneCallback;\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        canProcess: () => {\n          return !this.done && this.stack.length > 0 && this.queued.length < this.stack.length;\n        },\n      };\n\n      let processor = createProcessor<T>(nextCallback<T, TReturn, TNext>(this), processorOptions, (err) => {\n        if (!this.destroyed) this.processors.remove(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      this._pump();\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, { done: true, value: null });\n    while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, { done: true, value: null });\n    while (this.stack.length > 0) this.stack.pop();\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  private _pump() {\n    if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    while (this.stack.length > 0 && this.queued.length > 0) {\n      this._processOrQueue(this.queued.pop());\n      if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    }\n  }\n\n  private _processOrQueue(callback: ProcessCallback<T>): undefined {\n    if (this.done) {\n      callback(null, { done: true, value: null });\n      return;\n    }\n\n    // nothing to process so queue\n    if (this.stack.length === 0) {\n      this.queued.push(callback);\n      return;\n    }\n\n    // process next\n    const next = this.stack.pop();\n    this.processing.push(callback);\n    next(this, (err?: Error, result?: IteratorResult<T, TReturn> | undefined): undefined => {\n      this.processing.remove(callback);\n\n      // done\n      if (this.done)\n        return callback(null, {\n          done: true,\n          value: null,\n        });\n\n      // skip error\n      if (err && compat.defaultValue(this.options.error(err), true)) err = null;\n\n      // handle callback\n      if (err) callback(err);\n      else if (!result) this._processOrQueue(callback);\n      else callback(null, result);\n\n      // done\n      if (this.stack.length === 0 && this.processing.length === 0 && !this.done) this.end(); // end\n    });\n  }\n}\n"],"names":["LinkedList","StackBaseIterator","Symbol","global","asyncIterator","undefined","options","error","defaultError","err","done","stack","queued","processors","processing","isDone","push","fn","rest","console","log","length","forEach","x","_pump","next","Pinkie","resolve","reject","_processOrQueue","result","callback","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","total","counter","canProcess","processor","createProcessor","nextCallback","destroyed","remove","end","Promise","pop","value","destroy","last","compat","defaultValue"],"mappings":";;;;;;;;;;;QAaoBA;eAAAA,qBAAU;;;eAETC;;;kEAfF;2EACM;gCACO;oEACb;mEACI;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAMvB,+DAA+D;AAC/D,IAAMC,SAA4B,OAAOC,OAAOD,MAAM,KAAK,cAAe;IAAEE,eAAeC;AAAU,IAAqCF,OAAOD,MAAM;AAIxI,IAAA,AAAMD,kCAAN;;aAAMA;YAUPK,UAAAA,iEAAwB,CAAC;gCAVlBL;QAWjB,IAAI,CAACK,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,EAAE;QACf,IAAI,CAACC,MAAM,GAAG,EAAE;QAChB,IAAI,CAACC,UAAU,GAAG,IAAIb,qBAAU;QAChC,IAAI,CAACc,UAAU,GAAG,IAAId,qBAAU;;iBAtBfC;IAyBnBc,OAAAA,MAEC,GAFDA,SAAAA;QACE,OAAO,IAAI,CAACL,IAAI;IAClB;IAEAM,OAAAA,IAKC,GALDA,SAAAA,KAAKC,EAAoC;;QAAE,IAAA,IAAA,OAAA,UAAA,QAAA,AAAGC,OAAH,UAAA,OAAA,IAAA,OAAA,QAAA,OAAA,GAAA,OAAA,MAAA;YAAGA,KAAH,OAAA,KAAA,SAAA,CAAA,KAA2C;;QACpF,IAAI,IAAI,CAACR,IAAI,EAAE,OAAOS,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACT,KAAK,CAACK,IAAI,CAACC;QAChB,CAACC,KAAKG,MAAM,IAAIH,KAAKI,OAAO,CAAC,SAACC;mBAAM,MAAKZ,KAAK,CAACK,IAAI,CAACO;;QACpD,IAAI,CAACC,KAAK;IACZ;IAEAC,OAAAA,IAMC,GANDA,SAAAA;;QACE,OAAO,IAAIC,sBAAM,CAAC,SAACC,SAASC;YAC1B,MAAKC,eAAe,CAAC,SAACpB,KAAKqB;gBACzBrB,MAAMmB,OAAOnB,OAAOkB,QAAQG;YAC9B;QACF;IACF;IAEA,MAAA,CAAC5B,OAAOE,aAAa,CAAC,AAErB,GAFD;QACE,OAAO,IAAI;IACb;IAEAkB,OAAAA,OAgDC,GAhDDA,SAAAA,QAAQL,EAAmB,EAAEX,OAA2C,EAAEyB,QAA2B;;QACnG,IAAI,OAAOd,OAAO,YAAY,MAAM,IAAIe,MAAM;QAC9C,IAAI,OAAO1B,YAAY,YAAY;YACjCyB,WAAWzB;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOyB,aAAa,YAAY;YAClC,IAAI,IAAI,CAACrB,IAAI,EAAE;gBACbqB,SAAS,MAAM;gBACf;YACF;YACAzB,UAAUA,WAAW,CAAC;YACtB,IAAM2B,mBAAwC;gBAC5CC,MAAMjB;gBACNkB,WAAW7B,QAAQ6B,SAAS,IAAI;gBAChCC,aAAa9B,QAAQ8B,WAAW,IAAI;gBACpCC,OAAO/B,QAAQ+B,KAAK,IAAIC;gBACxB/B,OACED,QAAQC,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACF+B,OAAO;gBACPC,SAAS;gBACTC,YAAY;oBACV,OAAO,CAAC,MAAK/B,IAAI,IAAI,MAAKC,KAAK,CAACU,MAAM,GAAG,KAAK,MAAKT,MAAM,CAACS,MAAM,GAAG,MAAKV,KAAK,CAACU,MAAM;gBACtF;YACF;YAEA,IAAIqB,YAAYC,IAAAA,iCAAe,EAAIC,IAAAA,6BAAY,EAAoB,IAAI,GAAGX,kBAAkB,SAACxB;gBAC3F,IAAI,CAAC,MAAKoC,SAAS,EAAE,MAAKhC,UAAU,CAACiC,MAAM,CAACJ;gBAC5CA,YAAY;gBACZpC,UAAU;gBACV,IAAMI,OAAO,CAAC,MAAKC,KAAK,CAACU,MAAM;gBAC/B,IAAI,AAACZ,CAAAA,OAAOC,IAAG,KAAM,CAAC,MAAKA,IAAI,EAAE,MAAKqC,GAAG,CAACtC;gBAC1C,OAAOsB,SAAStB,KAAK,MAAKC,IAAI,IAAIA;YACpC;YACA,IAAI,CAACG,UAAU,CAACG,IAAI,CAAC0B;YACrB,IAAI,CAAClB,KAAK;YACV;QACF;QAEA,OAAO,IAAIwB,QAAQ,SAACrB,SAASC;mBAC3B,MAAKN,OAAO,CAACL,IAAIX,SAAS,SAACG,KAAaC;gBACtCD,MAAMmB,OAAOnB,OAAOkB,QAAQjB;YAC9B;;IAEJ;IAEAqC,OAAAA,GAOC,GAPDA,SAAAA,IAAItC,GAAW;QACb,IAAI,IAAI,CAACC,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,EAAG,IAAI,CAACR,UAAU,CAACoC,GAAG,GAAGxC,OAAO;QAChE,MAAO,IAAI,CAACK,UAAU,CAACO,MAAM,GAAG,EAAGZ,MAAM,IAAI,CAACK,UAAU,CAACmC,GAAG,GAAGxC,OAAO,IAAI,CAACK,UAAU,CAACmC,GAAG,GAAG,MAAM;YAAEvC,MAAM;YAAMwC,OAAO;QAAK;QAC5H,MAAO,IAAI,CAACtC,MAAM,CAACS,MAAM,GAAG,EAAGZ,MAAM,IAAI,CAACG,MAAM,CAACqC,GAAG,GAAGxC,OAAO,IAAI,CAACG,MAAM,CAACqC,GAAG,GAAG,MAAM;YAAEvC,MAAM;YAAMwC,OAAO;QAAK;QAChH,MAAO,IAAI,CAACvC,KAAK,CAACU,MAAM,GAAG,EAAG,IAAI,CAACV,KAAK,CAACsC,GAAG;IAC9C;IACAE,OAAAA,OAIC,GAJDA,SAAAA,QAAQ1C,GAAW;QACjB,IAAI,IAAI,CAACoC,SAAS,EAAE,MAAM,IAAIb,MAAM;QACpC,IAAI,CAACa,SAAS,GAAG;QACjB,IAAI,CAACE,GAAG,CAACtC;IACX;IAEA,OAAQe,KAMP,GAND,SAAQA;QACN,IAAI,CAAC,IAAI,CAACd,IAAI,IAAI,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,IAAI,CAACT,MAAM,CAACS,MAAM,EAAE,IAAI,CAACR,UAAU,CAACuC,IAAI,GAAG,QAAQ,oBAAoB;QACpK,MAAO,IAAI,CAACzC,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACT,MAAM,CAACS,MAAM,GAAG,EAAG;YACtD,IAAI,CAACQ,eAAe,CAAC,IAAI,CAACjB,MAAM,CAACqC,GAAG;YACpC,IAAI,CAAC,IAAI,CAACvC,IAAI,IAAI,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,IAAI,CAACT,MAAM,CAACS,MAAM,EAAE,IAAI,CAACR,UAAU,CAACuC,IAAI,GAAG,QAAQ,oBAAoB;QACtK;IACF;IAEA,OAAQvB,eAoCP,GApCD,SAAQA,gBAAgBE,QAA4B;;QAClD,IAAI,IAAI,CAACrB,IAAI,EAAE;YACbqB,SAAS,MAAM;gBAAErB,MAAM;gBAAMwC,OAAO;YAAK;YACzC;QACF;QAEA,8BAA8B;QAC9B,IAAI,IAAI,CAACvC,KAAK,CAACU,MAAM,KAAK,GAAG;YAC3B,IAAI,CAACT,MAAM,CAACI,IAAI,CAACe;YACjB;QACF;QAEA,eAAe;QACf,IAAMN,OAAO,IAAI,CAACd,KAAK,CAACsC,GAAG;QAC3B,IAAI,CAACnC,UAAU,CAACE,IAAI,CAACe;QACrBN,KAAK,IAAI,EAAE,SAAChB,KAAaqB;YACvB,MAAKhB,UAAU,CAACgC,MAAM,CAACf;YAEvB,OAAO;YACP,IAAI,MAAKrB,IAAI,EACX,OAAOqB,SAAS,MAAM;gBACpBrB,MAAM;gBACNwC,OAAO;YACT;YAEF,aAAa;YACb,IAAIzC,OAAO4C,oBAAM,CAACC,YAAY,CAAC,MAAKhD,OAAO,CAACC,KAAK,CAACE,MAAM,OAAOA,MAAM;YAErE,kBAAkB;YAClB,IAAIA,KAAKsB,SAAStB;iBACb,IAAI,CAACqB,QAAQ,MAAKD,eAAe,CAACE;iBAClCA,SAAS,MAAMD;YAEpB,OAAO;YACP,IAAI,MAAKnB,KAAK,CAACU,MAAM,KAAK,KAAK,MAAKP,UAAU,CAACO,MAAM,KAAK,KAAK,CAAC,MAAKX,IAAI,EAAE,MAAKqC,GAAG,IAAI,MAAM;QAC/F;IACF;WA5JmB9C"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import compat from 'async-compat';\nimport nextCallback from 'iterator-next-callback';\nimport { createProcessor } from 'maximize-iterator';\nimport Pinkie from 'pinkie-promise';\nimport LinkedList from './LinkedList.ts';\n\nimport type { EachDoneCallback, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackOptions, ValueCallback } from './types.ts';\n\nexport type StackFunction<T, TReturn = unknown, TNext = unknown> = (iterator: StackBaseIterator<T, TReturn, TNext>, callback: ValueCallback<T>) => void;\n\nconst root = typeof window === 'undefined' ? global : window;\n// biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy\nconst Symbol: SymbolConstructor = typeof root.Symbol === 'undefined' ? ({ asyncIterator: undefined } as unknown as SymbolConstructor) : root.Symbol;\n\nexport { default as LinkedList } from './LinkedList.ts';\nexport type * from './types.ts';\nexport default class StackBaseIterator<T, TReturn = unknown, TNext = unknown> implements AsyncIterableIterator<T, TReturn, TNext> {\n  protected done: boolean;\n  protected stack: StackFunction<T, TReturn, TNext>[];\n  protected queued: ProcessCallback<T>[];\n  protected processors: LinkedList<Processor>;\n  protected processing: LinkedList<ProcessCallback<T>>;\n\n  protected options: StackOptions;\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 = [] as StackFunction<T, TReturn, TNext>[];\n    this.queued = [] as ProcessCallback<T>[];\n    this.processors = new LinkedList<Processor>();\n    this.processing = new LinkedList<ProcessCallback<T>>();\n  }\n\n  isDone() {\n    return this.done;\n  }\n\n  push(fn: StackFunction<T, TReturn, TNext>, ...rest: StackFunction<T, TReturn, TNext>[]) {\n    if (this.done) return console.log('Attempting to push on a done iterator');\n    this.stack.push(fn);\n    !rest.length || rest.forEach((x) => this.stack.push(x));\n    this._pump();\n  }\n\n  next(): Promise<IteratorResult<T, TReturn>> {\n    return new Pinkie((resolve, reject) => {\n      this._processOrQueue((err, result: IteratorResult<T, TReturn>) => {\n        err ? reject(err) : resolve(result);\n      });\n    });\n  }\n\n  [Symbol.asyncIterator](): AsyncIterableIterator<T, TReturn, TNext> {\n    return this;\n  }\n\n  forEach(fn: EachFunction<T>, options?: ForEachOptions | EachDoneCallback, callback?: EachDoneCallback): undefined | Promise<boolean> {\n    if (typeof fn !== 'function') throw new Error('Missing each function');\n    if (typeof options === 'function') {\n      callback = options as EachDoneCallback;\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        canProcess: () => {\n          return !this.done && this.stack.length > 0 && this.queued.length < this.stack.length;\n        },\n      };\n\n      let processor = createProcessor<T>(nextCallback<T, TReturn, TNext>(this), processorOptions, (err) => {\n        if (!this.destroyed) this.processors.remove(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      this._pump();\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, { done: true, value: null });\n    while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, { done: true, value: null });\n    while (this.stack.length > 0) this.stack.pop();\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  private _pump() {\n    if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    while (this.stack.length > 0 && this.queued.length > 0) {\n      this._processOrQueue(this.queued.pop());\n      if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    }\n  }\n\n  private _processOrQueue(callback: ProcessCallback<T>): undefined {\n    if (this.done) {\n      callback(null, { done: true, value: null });\n      return;\n    }\n\n    // nothing to process so queue\n    if (this.stack.length === 0) {\n      this.queued.push(callback);\n      return;\n    }\n\n    // process next\n    const next = this.stack.pop();\n    this.processing.push(callback);\n    next(this, (err?: Error, result?: IteratorResult<T, TReturn> | undefined): undefined => {\n      this.processing.remove(callback);\n\n      // done\n      if (this.done)\n        return callback(null, {\n          done: true,\n          value: null,\n        });\n\n      // skip error\n      if (err && compat.defaultValue(this.options.error(err), true)) err = null;\n\n      // handle callback\n      if (err) callback(err);\n      else if (!result) this._processOrQueue(callback);\n      else callback(null, result);\n\n      // done\n      if (this.stack.length === 0 && this.processing.length === 0 && !this.done) this.end(); // end\n    });\n  }\n}\n"],"names":["LinkedList","StackBaseIterator","root","window","global","Symbol","asyncIterator","undefined","options","error","defaultError","err","done","stack","queued","processors","processing","isDone","push","fn","rest","console","log","length","forEach","x","_pump","next","Pinkie","resolve","reject","_processOrQueue","result","callback","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","total","counter","canProcess","processor","createProcessor","nextCallback","destroyed","remove","end","Promise","pop","value","destroy","last","compat","defaultValue"],"mappings":";;;;;;;;;;;QAcoBA;eAAAA,qBAAU;;;eAETC;;;kEAhBF;2EACM;gCACO;oEACb;mEACI;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAMvB,IAAMC,OAAO,OAAOC,WAAW,cAAcC,SAASD;AACtD,+DAA+D;AAC/D,IAAME,SAA4B,OAAOH,KAAKG,MAAM,KAAK,cAAe;IAAEC,eAAeC;AAAU,IAAqCL,KAAKG,MAAM;AAIpI,IAAA,AAAMJ,kCAAN;;aAAMA;YAUPO,UAAAA,iEAAwB,CAAC;gCAVlBP;QAWjB,IAAI,CAACO,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,EAAE;QACf,IAAI,CAACC,MAAM,GAAG,EAAE;QAChB,IAAI,CAACC,UAAU,GAAG,IAAIf,qBAAU;QAChC,IAAI,CAACgB,UAAU,GAAG,IAAIhB,qBAAU;;iBAtBfC;IAyBnBgB,OAAAA,MAEC,GAFDA,SAAAA;QACE,OAAO,IAAI,CAACL,IAAI;IAClB;IAEAM,OAAAA,IAKC,GALDA,SAAAA,KAAKC,EAAoC;;QAAE,IAAA,IAAA,OAAA,UAAA,QAAA,AAAGC,OAAH,UAAA,OAAA,IAAA,OAAA,QAAA,OAAA,GAAA,OAAA,MAAA;YAAGA,KAAH,OAAA,KAAA,SAAA,CAAA,KAA2C;;QACpF,IAAI,IAAI,CAACR,IAAI,EAAE,OAAOS,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACT,KAAK,CAACK,IAAI,CAACC;QAChB,CAACC,KAAKG,MAAM,IAAIH,KAAKI,OAAO,CAAC,SAACC;mBAAM,MAAKZ,KAAK,CAACK,IAAI,CAACO;;QACpD,IAAI,CAACC,KAAK;IACZ;IAEAC,OAAAA,IAMC,GANDA,SAAAA;;QACE,OAAO,IAAIC,sBAAM,CAAC,SAACC,SAASC;YAC1B,MAAKC,eAAe,CAAC,SAACpB,KAAKqB;gBACzBrB,MAAMmB,OAAOnB,OAAOkB,QAAQG;YAC9B;QACF;IACF;IAEA,MAAA,CAAC3B,OAAOC,aAAa,CAAC,AAErB,GAFD;QACE,OAAO,IAAI;IACb;IAEAkB,OAAAA,OAgDC,GAhDDA,SAAAA,QAAQL,EAAmB,EAAEX,OAA2C,EAAEyB,QAA2B;;QACnG,IAAI,OAAOd,OAAO,YAAY,MAAM,IAAIe,MAAM;QAC9C,IAAI,OAAO1B,YAAY,YAAY;YACjCyB,WAAWzB;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOyB,aAAa,YAAY;YAClC,IAAI,IAAI,CAACrB,IAAI,EAAE;gBACbqB,SAAS,MAAM;gBACf;YACF;YACAzB,UAAUA,WAAW,CAAC;YACtB,IAAM2B,mBAAwC;gBAC5CC,MAAMjB;gBACNkB,WAAW7B,QAAQ6B,SAAS,IAAI;gBAChCC,aAAa9B,QAAQ8B,WAAW,IAAI;gBACpCC,OAAO/B,QAAQ+B,KAAK,IAAIC;gBACxB/B,OACED,QAAQC,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACF+B,OAAO;gBACPC,SAAS;gBACTC,YAAY;oBACV,OAAO,CAAC,MAAK/B,IAAI,IAAI,MAAKC,KAAK,CAACU,MAAM,GAAG,KAAK,MAAKT,MAAM,CAACS,MAAM,GAAG,MAAKV,KAAK,CAACU,MAAM;gBACtF;YACF;YAEA,IAAIqB,YAAYC,IAAAA,iCAAe,EAAIC,IAAAA,6BAAY,EAAoB,IAAI,GAAGX,kBAAkB,SAACxB;gBAC3F,IAAI,CAAC,MAAKoC,SAAS,EAAE,MAAKhC,UAAU,CAACiC,MAAM,CAACJ;gBAC5CA,YAAY;gBACZpC,UAAU;gBACV,IAAMI,OAAO,CAAC,MAAKC,KAAK,CAACU,MAAM;gBAC/B,IAAI,AAACZ,CAAAA,OAAOC,IAAG,KAAM,CAAC,MAAKA,IAAI,EAAE,MAAKqC,GAAG,CAACtC;gBAC1C,OAAOsB,SAAStB,KAAK,MAAKC,IAAI,IAAIA;YACpC;YACA,IAAI,CAACG,UAAU,CAACG,IAAI,CAAC0B;YACrB,IAAI,CAAClB,KAAK;YACV;QACF;QAEA,OAAO,IAAIwB,QAAQ,SAACrB,SAASC;mBAC3B,MAAKN,OAAO,CAACL,IAAIX,SAAS,SAACG,KAAaC;gBACtCD,MAAMmB,OAAOnB,OAAOkB,QAAQjB;YAC9B;;IAEJ;IAEAqC,OAAAA,GAOC,GAPDA,SAAAA,IAAItC,GAAW;QACb,IAAI,IAAI,CAACC,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,EAAG,IAAI,CAACR,UAAU,CAACoC,GAAG,GAAGxC,OAAO;QAChE,MAAO,IAAI,CAACK,UAAU,CAACO,MAAM,GAAG,EAAGZ,MAAM,IAAI,CAACK,UAAU,CAACmC,GAAG,GAAGxC,OAAO,IAAI,CAACK,UAAU,CAACmC,GAAG,GAAG,MAAM;YAAEvC,MAAM;YAAMwC,OAAO;QAAK;QAC5H,MAAO,IAAI,CAACtC,MAAM,CAACS,MAAM,GAAG,EAAGZ,MAAM,IAAI,CAACG,MAAM,CAACqC,GAAG,GAAGxC,OAAO,IAAI,CAACG,MAAM,CAACqC,GAAG,GAAG,MAAM;YAAEvC,MAAM;YAAMwC,OAAO;QAAK;QAChH,MAAO,IAAI,CAACvC,KAAK,CAACU,MAAM,GAAG,EAAG,IAAI,CAACV,KAAK,CAACsC,GAAG;IAC9C;IACAE,OAAAA,OAIC,GAJDA,SAAAA,QAAQ1C,GAAW;QACjB,IAAI,IAAI,CAACoC,SAAS,EAAE,MAAM,IAAIb,MAAM;QACpC,IAAI,CAACa,SAAS,GAAG;QACjB,IAAI,CAACE,GAAG,CAACtC;IACX;IAEA,OAAQe,KAMP,GAND,SAAQA;QACN,IAAI,CAAC,IAAI,CAACd,IAAI,IAAI,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,IAAI,CAACT,MAAM,CAACS,MAAM,EAAE,IAAI,CAACR,UAAU,CAACuC,IAAI,GAAG,QAAQ,oBAAoB;QACpK,MAAO,IAAI,CAACzC,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACT,MAAM,CAACS,MAAM,GAAG,EAAG;YACtD,IAAI,CAACQ,eAAe,CAAC,IAAI,CAACjB,MAAM,CAACqC,GAAG;YACpC,IAAI,CAAC,IAAI,CAACvC,IAAI,IAAI,IAAI,CAACG,UAAU,CAACQ,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,KAAK,IAAI,CAACV,KAAK,CAACU,MAAM,GAAG,IAAI,CAACT,MAAM,CAACS,MAAM,EAAE,IAAI,CAACR,UAAU,CAACuC,IAAI,GAAG,QAAQ,oBAAoB;QACtK;IACF;IAEA,OAAQvB,eAoCP,GApCD,SAAQA,gBAAgBE,QAA4B;;QAClD,IAAI,IAAI,CAACrB,IAAI,EAAE;YACbqB,SAAS,MAAM;gBAAErB,MAAM;gBAAMwC,OAAO;YAAK;YACzC;QACF;QAEA,8BAA8B;QAC9B,IAAI,IAAI,CAACvC,KAAK,CAACU,MAAM,KAAK,GAAG;YAC3B,IAAI,CAACT,MAAM,CAACI,IAAI,CAACe;YACjB;QACF;QAEA,eAAe;QACf,IAAMN,OAAO,IAAI,CAACd,KAAK,CAACsC,GAAG;QAC3B,IAAI,CAACnC,UAAU,CAACE,IAAI,CAACe;QACrBN,KAAK,IAAI,EAAE,SAAChB,KAAaqB;YACvB,MAAKhB,UAAU,CAACgC,MAAM,CAACf;YAEvB,OAAO;YACP,IAAI,MAAKrB,IAAI,EACX,OAAOqB,SAAS,MAAM;gBACpBrB,MAAM;gBACNwC,OAAO;YACT;YAEF,aAAa;YACb,IAAIzC,OAAO4C,oBAAM,CAACC,YAAY,CAAC,MAAKhD,OAAO,CAACC,KAAK,CAACE,MAAM,OAAOA,MAAM;YAErE,kBAAkB;YAClB,IAAIA,KAAKsB,SAAStB;iBACb,IAAI,CAACqB,QAAQ,MAAKD,eAAe,CAACE;iBAClCA,SAAS,MAAMD;YAEpB,OAAO;YACP,IAAI,MAAKnB,KAAK,CAACU,MAAM,KAAK,KAAK,MAAKP,UAAU,CAACO,MAAM,KAAK,KAAK,CAAC,MAAKX,IAAI,EAAE,MAAKqC,GAAG,IAAI,MAAM;QAC/F;IACF;WA5JmBhD"}

dist/esm/index.js

@@ -6,6 +6,7 @@ import compat from 'async-compat';
 import LinkedList from './LinkedList.js';
+const root = typeof window === 'undefined' ? global : window;
 // biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy
-const Symbol = typeof global.Symbol === 'undefined' ? {
+const Symbol = typeof root.Symbol === 'undefined' ? {
     asyncIterator: undefined
-} : global.Symbol;
+} : root.Symbol;
 export { default as LinkedList } from './LinkedList.js';
@@ -12,0 +13,0 @@ let StackBaseIterator = class StackBaseIterator {

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 compat from 'async-compat';\nimport nextCallback from 'iterator-next-callback';\nimport { createProcessor } from 'maximize-iterator';\nimport Pinkie from 'pinkie-promise';\nimport LinkedList from './LinkedList.ts';\n\nimport type { EachDoneCallback, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackOptions, ValueCallback } from './types.ts';\n\nexport type StackFunction<T, TReturn = unknown, TNext = unknown> = (iterator: StackBaseIterator<T, TReturn, TNext>, callback: ValueCallback<T>) => void;\n\n// biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy\nconst Symbol: SymbolConstructor = typeof global.Symbol === 'undefined' ? ({ asyncIterator: undefined } as unknown as SymbolConstructor) : global.Symbol;\n\nexport { default as LinkedList } from './LinkedList.ts';\nexport type * from './types.ts';\nexport default class StackBaseIterator<T, TReturn = unknown, TNext = unknown> implements AsyncIterableIterator<T, TReturn, TNext> {\n  protected done: boolean;\n  protected stack: StackFunction<T, TReturn, TNext>[];\n  protected queued: ProcessCallback<T>[];\n  protected processors: LinkedList<Processor>;\n  protected processing: LinkedList<ProcessCallback<T>>;\n\n  protected options: StackOptions;\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 = [] as StackFunction<T, TReturn, TNext>[];\n    this.queued = [] as ProcessCallback<T>[];\n    this.processors = new LinkedList<Processor>();\n    this.processing = new LinkedList<ProcessCallback<T>>();\n  }\n\n  isDone() {\n    return this.done;\n  }\n\n  push(fn: StackFunction<T, TReturn, TNext>, ...rest: StackFunction<T, TReturn, TNext>[]) {\n    if (this.done) return console.log('Attempting to push on a done iterator');\n    this.stack.push(fn);\n    !rest.length || rest.forEach((x) => this.stack.push(x));\n    this._pump();\n  }\n\n  next(): Promise<IteratorResult<T, TReturn>> {\n    return new Pinkie((resolve, reject) => {\n      this._processOrQueue((err, result: IteratorResult<T, TReturn>) => {\n        err ? reject(err) : resolve(result);\n      });\n    });\n  }\n\n  [Symbol.asyncIterator](): AsyncIterableIterator<T, TReturn, TNext> {\n    return this;\n  }\n\n  forEach(fn: EachFunction<T>, options?: ForEachOptions | EachDoneCallback, callback?: EachDoneCallback): undefined | Promise<boolean> {\n    if (typeof fn !== 'function') throw new Error('Missing each function');\n    if (typeof options === 'function') {\n      callback = options as EachDoneCallback;\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        canProcess: () => {\n          return !this.done && this.stack.length > 0 && this.queued.length < this.stack.length;\n        },\n      };\n\n      let processor = createProcessor<T>(nextCallback<T, TReturn, TNext>(this), processorOptions, (err) => {\n        if (!this.destroyed) this.processors.remove(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      this._pump();\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, { done: true, value: null });\n    while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, { done: true, value: null });\n    while (this.stack.length > 0) this.stack.pop();\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  private _pump() {\n    if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    while (this.stack.length > 0 && this.queued.length > 0) {\n      this._processOrQueue(this.queued.pop());\n      if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    }\n  }\n\n  private _processOrQueue(callback: ProcessCallback<T>): undefined {\n    if (this.done) {\n      callback(null, { done: true, value: null });\n      return;\n    }\n\n    // nothing to process so queue\n    if (this.stack.length === 0) {\n      this.queued.push(callback);\n      return;\n    }\n\n    // process next\n    const next = this.stack.pop();\n    this.processing.push(callback);\n    next(this, (err?: Error, result?: IteratorResult<T, TReturn> | undefined): undefined => {\n      this.processing.remove(callback);\n\n      // done\n      if (this.done)\n        return callback(null, {\n          done: true,\n          value: null,\n        });\n\n      // skip error\n      if (err && compat.defaultValue(this.options.error(err), true)) err = null;\n\n      // handle callback\n      if (err) callback(err);\n      else if (!result) this._processOrQueue(callback);\n      else callback(null, result);\n\n      // done\n      if (this.stack.length === 0 && this.processing.length === 0 && !this.done) this.end(); // end\n    });\n  }\n}\n"],"names":["compat","nextCallback","createProcessor","Pinkie","LinkedList","Symbol","global","asyncIterator","undefined","default","StackBaseIterator","isDone","done","push","fn","rest","console","log","stack","length","forEach","x","_pump","next","resolve","reject","_processOrQueue","err","result","options","callback","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","error","defaultError","total","counter","canProcess","queued","processor","destroyed","processors","remove","end","Promise","pop","processing","value","destroy","last","defaultValue"],"mappings":"AAAA,OAAOA,YAAY,eAAe;AAClC,OAAOC,kBAAkB,yBAAyB;AAClD,SAASC,eAAe,QAAQ,oBAAoB;AACpD,OAAOC,YAAY,iBAAiB;AACpC,OAAOC,gBAAgB,kBAAkB;AAMzC,+DAA+D;AAC/D,MAAMC,SAA4B,OAAOC,OAAOD,MAAM,KAAK,cAAe;IAAEE,eAAeC;AAAU,IAAqCF,OAAOD,MAAM;AAEvJ,SAASI,WAAWL,UAAU,QAAQ,kBAAkB;AAEzC,IAAA,AAAMM,oBAAN,MAAMA;IAyBnBC,SAAS;QACP,OAAO,IAAI,CAACC,IAAI;IAClB;IAEAC,KAAKC,EAAoC,EAAE,GAAGC,IAAwC,EAAE;QACtF,IAAI,IAAI,CAACH,IAAI,EAAE,OAAOI,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACC,KAAK,CAACL,IAAI,CAACC;QAChB,CAACC,KAAKI,MAAM,IAAIJ,KAAKK,OAAO,CAAC,CAACC,IAAM,IAAI,CAACH,KAAK,CAACL,IAAI,CAACQ;QACpD,IAAI,CAACC,KAAK;IACZ;IAEAC,OAA4C;QAC1C,OAAO,IAAIpB,OAAO,CAACqB,SAASC;YAC1B,IAAI,CAACC,eAAe,CAAC,CAACC,KAAKC;gBACzBD,MAAMF,OAAOE,OAAOH,QAAQI;YAC9B;QACF;IACF;IAEA,CAACvB,OAAOE,aAAa,CAAC,GAA6C;QACjE,OAAO,IAAI;IACb;IAEAa,QAAQN,EAAmB,EAAEe,OAA2C,EAAEC,QAA2B,EAAgC;QACnI,IAAI,OAAOhB,OAAO,YAAY,MAAM,IAAIiB,MAAM;QAC9C,IAAI,OAAOF,YAAY,YAAY;YACjCC,WAAWD;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOC,aAAa,YAAY;YAClC,IAAI,IAAI,CAAClB,IAAI,EAAE;gBACbkB,SAAS,MAAM;gBACf;YACF;YACAD,UAAUA,WAAW,CAAC;YACtB,MAAMG,mBAAwC;gBAC5CC,MAAMnB;gBACNoB,WAAWL,QAAQK,SAAS,IAAI;gBAChCC,aAAaN,QAAQM,WAAW,IAAI;gBACpCC,OAAOP,QAAQO,KAAK,IAAIC;gBACxBC,OACET,QAAQS,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFC,OAAO;gBACPC,SAAS;gBACTC,YAAY;oBACV,OAAO,CAAC,IAAI,CAAC9B,IAAI,IAAI,IAAI,CAACM,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACwB,MAAM,CAACxB,MAAM,GAAG,IAAI,CAACD,KAAK,CAACC,MAAM;gBACtF;YACF;YAEA,IAAIyB,YAAY1C,gBAAmBD,aAAgC,IAAI,GAAG+B,kBAAkB,CAACL;gBAC3F,IAAI,CAAC,IAAI,CAACkB,SAAS,EAAE,IAAI,CAACC,UAAU,CAACC,MAAM,CAACH;gBAC5CA,YAAY;gBACZf,UAAU;gBACV,MAAMjB,OAAO,CAAC,IAAI,CAACM,KAAK,CAACC,MAAM;gBAC/B,IAAI,AAACQ,CAAAA,OAAOf,IAAG,KAAM,CAAC,IAAI,CAACA,IAAI,EAAE,IAAI,CAACoC,GAAG,CAACrB;gBAC1C,OAAOG,SAASH,KAAK,IAAI,CAACf,IAAI,IAAIA;YACpC;YACA,IAAI,CAACkC,UAAU,CAACjC,IAAI,CAAC+B;YACrB,IAAI,CAACtB,KAAK;YACV;QACF;QAEA,OAAO,IAAI2B,QAAQ,CAACzB,SAASC,SAC3B,IAAI,CAACL,OAAO,CAACN,IAAIe,SAAS,CAACF,KAAaf;gBACtCe,MAAMF,OAAOE,OAAOH,QAAQZ;YAC9B;IAEJ;IAEAoC,IAAIrB,GAAW,EAAE;QACf,IAAI,IAAI,CAACf,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,EAAG,IAAI,CAAC2B,UAAU,CAACI,GAAG,GAAGvB,OAAO;QAChE,MAAO,IAAI,CAACwB,UAAU,CAAChC,MAAM,GAAG,EAAGQ,MAAM,IAAI,CAACwB,UAAU,CAACD,GAAG,GAAGvB,OAAO,IAAI,CAACwB,UAAU,CAACD,GAAG,GAAG,MAAM;YAAEtC,MAAM;YAAMwC,OAAO;QAAK;QAC5H,MAAO,IAAI,CAACT,MAAM,CAACxB,MAAM,GAAG,EAAGQ,MAAM,IAAI,CAACgB,MAAM,CAACO,GAAG,GAAGvB,OAAO,IAAI,CAACgB,MAAM,CAACO,GAAG,GAAG,MAAM;YAAEtC,MAAM;YAAMwC,OAAO;QAAK;QAChH,MAAO,IAAI,CAAClC,KAAK,CAACC,MAAM,GAAG,EAAG,IAAI,CAACD,KAAK,CAACgC,GAAG;IAC9C;IACAG,QAAQ1B,GAAW,EAAE;QACnB,IAAI,IAAI,CAACkB,SAAS,EAAE,MAAM,IAAId,MAAM;QACpC,IAAI,CAACc,SAAS,GAAG;QACjB,IAAI,CAACG,GAAG,CAACrB;IACX;IAEQL,QAAQ;QACd,IAAI,CAAC,IAAI,CAACV,IAAI,IAAI,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,IAAI,CAACwB,MAAM,CAACxB,MAAM,EAAE,IAAI,CAAC2B,UAAU,CAACQ,IAAI,GAAG,QAAQ,oBAAoB;QACpK,MAAO,IAAI,CAACpC,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACwB,MAAM,CAACxB,MAAM,GAAG,EAAG;YACtD,IAAI,CAACO,eAAe,CAAC,IAAI,CAACiB,MAAM,CAACO,GAAG;YACpC,IAAI,CAAC,IAAI,CAACtC,IAAI,IAAI,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,IAAI,CAACwB,MAAM,CAACxB,MAAM,EAAE,IAAI,CAAC2B,UAAU,CAACQ,IAAI,GAAG,QAAQ,oBAAoB;QACtK;IACF;IAEQ5B,gBAAgBI,QAA4B,EAAa;QAC/D,IAAI,IAAI,CAAClB,IAAI,EAAE;YACbkB,SAAS,MAAM;gBAAElB,MAAM;gBAAMwC,OAAO;YAAK;YACzC;QACF;QAEA,8BAA8B;QAC9B,IAAI,IAAI,CAAClC,KAAK,CAACC,MAAM,KAAK,GAAG;YAC3B,IAAI,CAACwB,MAAM,CAAC9B,IAAI,CAACiB;YACjB;QACF;QAEA,eAAe;QACf,MAAMP,OAAO,IAAI,CAACL,KAAK,CAACgC,GAAG;QAC3B,IAAI,CAACC,UAAU,CAACtC,IAAI,CAACiB;QACrBP,KAAK,IAAI,EAAE,CAACI,KAAaC;YACvB,IAAI,CAACuB,UAAU,CAACJ,MAAM,CAACjB;YAEvB,OAAO;YACP,IAAI,IAAI,CAAClB,IAAI,EACX,OAAOkB,SAAS,MAAM;gBACpBlB,MAAM;gBACNwC,OAAO;YACT;YAEF,aAAa;YACb,IAAIzB,OAAO3B,OAAOuD,YAAY,CAAC,IAAI,CAAC1B,OAAO,CAACS,KAAK,CAACX,MAAM,OAAOA,MAAM;YAErE,kBAAkB;YAClB,IAAIA,KAAKG,SAASH;iBACb,IAAI,CAACC,QAAQ,IAAI,CAACF,eAAe,CAACI;iBAClCA,SAAS,MAAMF;YAEpB,OAAO;YACP,IAAI,IAAI,CAACV,KAAK,CAACC,MAAM,KAAK,KAAK,IAAI,CAACgC,UAAU,CAAChC,MAAM,KAAK,KAAK,CAAC,IAAI,CAACP,IAAI,EAAE,IAAI,CAACoC,GAAG,IAAI,MAAM;QAC/F;IACF;IAlJA,YAAYnB,UAAwB,CAAC,CAAC,CAAE;QACtC,IAAI,CAACA,OAAO,GAAG;YAAE,GAAGA,OAAO;QAAC;QAC5B,IAAI,CAACA,OAAO,CAACS,KAAK,GAChBT,QAAQS,KAAK,IACb,SAASC,aAAaZ,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACf,IAAI,GAAG;QACZ,IAAI,CAACM,KAAK,GAAG,EAAE;QACf,IAAI,CAACyB,MAAM,GAAG,EAAE;QAChB,IAAI,CAACG,UAAU,GAAG,IAAI1C;QACtB,IAAI,CAAC+C,UAAU,GAAG,IAAI/C;IACxB;AAsIF;AA7JA,SAAqBM,+BA6JpB"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/stack-base-iterator/src/index.ts"],"sourcesContent":["import compat from 'async-compat';\nimport nextCallback from 'iterator-next-callback';\nimport { createProcessor } from 'maximize-iterator';\nimport Pinkie from 'pinkie-promise';\nimport LinkedList from './LinkedList.ts';\n\nimport type { EachDoneCallback, EachFunction, ForEachOptions, ProcessCallback, Processor, ProcessorOptions, StackOptions, ValueCallback } from './types.ts';\n\nexport type StackFunction<T, TReturn = unknown, TNext = unknown> = (iterator: StackBaseIterator<T, TReturn, TNext>, callback: ValueCallback<T>) => void;\n\nconst root = typeof window === 'undefined' ? global : window;\n// biome-ignore lint/suspicious/noShadowRestrictedNames: Legacy\nconst Symbol: SymbolConstructor = typeof root.Symbol === 'undefined' ? ({ asyncIterator: undefined } as unknown as SymbolConstructor) : root.Symbol;\n\nexport { default as LinkedList } from './LinkedList.ts';\nexport type * from './types.ts';\nexport default class StackBaseIterator<T, TReturn = unknown, TNext = unknown> implements AsyncIterableIterator<T, TReturn, TNext> {\n  protected done: boolean;\n  protected stack: StackFunction<T, TReturn, TNext>[];\n  protected queued: ProcessCallback<T>[];\n  protected processors: LinkedList<Processor>;\n  protected processing: LinkedList<ProcessCallback<T>>;\n\n  protected options: StackOptions;\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 = [] as StackFunction<T, TReturn, TNext>[];\n    this.queued = [] as ProcessCallback<T>[];\n    this.processors = new LinkedList<Processor>();\n    this.processing = new LinkedList<ProcessCallback<T>>();\n  }\n\n  isDone() {\n    return this.done;\n  }\n\n  push(fn: StackFunction<T, TReturn, TNext>, ...rest: StackFunction<T, TReturn, TNext>[]) {\n    if (this.done) return console.log('Attempting to push on a done iterator');\n    this.stack.push(fn);\n    !rest.length || rest.forEach((x) => this.stack.push(x));\n    this._pump();\n  }\n\n  next(): Promise<IteratorResult<T, TReturn>> {\n    return new Pinkie((resolve, reject) => {\n      this._processOrQueue((err, result: IteratorResult<T, TReturn>) => {\n        err ? reject(err) : resolve(result);\n      });\n    });\n  }\n\n  [Symbol.asyncIterator](): AsyncIterableIterator<T, TReturn, TNext> {\n    return this;\n  }\n\n  forEach(fn: EachFunction<T>, options?: ForEachOptions | EachDoneCallback, callback?: EachDoneCallback): undefined | Promise<boolean> {\n    if (typeof fn !== 'function') throw new Error('Missing each function');\n    if (typeof options === 'function') {\n      callback = options as EachDoneCallback;\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        canProcess: () => {\n          return !this.done && this.stack.length > 0 && this.queued.length < this.stack.length;\n        },\n      };\n\n      let processor = createProcessor<T>(nextCallback<T, TReturn, TNext>(this), processorOptions, (err) => {\n        if (!this.destroyed) this.processors.remove(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      this._pump();\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, { done: true, value: null });\n    while (this.queued.length > 0) err ? this.queued.pop()(err) : this.queued.pop()(null, { done: true, value: null });\n    while (this.stack.length > 0) this.stack.pop();\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  private _pump() {\n    if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    while (this.stack.length > 0 && this.queued.length > 0) {\n      this._processOrQueue(this.queued.pop());\n      if (!this.done && this.processors.length > 0 && this.stack.length > 0 && this.stack.length > this.queued.length) this.processors.last()(false); // try to queue more\n    }\n  }\n\n  private _processOrQueue(callback: ProcessCallback<T>): undefined {\n    if (this.done) {\n      callback(null, { done: true, value: null });\n      return;\n    }\n\n    // nothing to process so queue\n    if (this.stack.length === 0) {\n      this.queued.push(callback);\n      return;\n    }\n\n    // process next\n    const next = this.stack.pop();\n    this.processing.push(callback);\n    next(this, (err?: Error, result?: IteratorResult<T, TReturn> | undefined): undefined => {\n      this.processing.remove(callback);\n\n      // done\n      if (this.done)\n        return callback(null, {\n          done: true,\n          value: null,\n        });\n\n      // skip error\n      if (err && compat.defaultValue(this.options.error(err), true)) err = null;\n\n      // handle callback\n      if (err) callback(err);\n      else if (!result) this._processOrQueue(callback);\n      else callback(null, result);\n\n      // done\n      if (this.stack.length === 0 && this.processing.length === 0 && !this.done) this.end(); // end\n    });\n  }\n}\n"],"names":["compat","nextCallback","createProcessor","Pinkie","LinkedList","root","window","global","Symbol","asyncIterator","undefined","default","StackBaseIterator","isDone","done","push","fn","rest","console","log","stack","length","forEach","x","_pump","next","resolve","reject","_processOrQueue","err","result","options","callback","Error","processorOptions","each","callbacks","concurrency","limit","Infinity","error","defaultError","total","counter","canProcess","queued","processor","destroyed","processors","remove","end","Promise","pop","processing","value","destroy","last","defaultValue"],"mappings":"AAAA,OAAOA,YAAY,eAAe;AAClC,OAAOC,kBAAkB,yBAAyB;AAClD,SAASC,eAAe,QAAQ,oBAAoB;AACpD,OAAOC,YAAY,iBAAiB;AACpC,OAAOC,gBAAgB,kBAAkB;AAMzC,MAAMC,OAAO,OAAOC,WAAW,cAAcC,SAASD;AACtD,+DAA+D;AAC/D,MAAME,SAA4B,OAAOH,KAAKG,MAAM,KAAK,cAAe;IAAEC,eAAeC;AAAU,IAAqCL,KAAKG,MAAM;AAEnJ,SAASG,WAAWP,UAAU,QAAQ,kBAAkB;AAEzC,IAAA,AAAMQ,oBAAN,MAAMA;IAyBnBC,SAAS;QACP,OAAO,IAAI,CAACC,IAAI;IAClB;IAEAC,KAAKC,EAAoC,EAAE,GAAGC,IAAwC,EAAE;QACtF,IAAI,IAAI,CAACH,IAAI,EAAE,OAAOI,QAAQC,GAAG,CAAC;QAClC,IAAI,CAACC,KAAK,CAACL,IAAI,CAACC;QAChB,CAACC,KAAKI,MAAM,IAAIJ,KAAKK,OAAO,CAAC,CAACC,IAAM,IAAI,CAACH,KAAK,CAACL,IAAI,CAACQ;QACpD,IAAI,CAACC,KAAK;IACZ;IAEAC,OAA4C;QAC1C,OAAO,IAAItB,OAAO,CAACuB,SAASC;YAC1B,IAAI,CAACC,eAAe,CAAC,CAACC,KAAKC;gBACzBD,MAAMF,OAAOE,OAAOH,QAAQI;YAC9B;QACF;IACF;IAEA,CAACtB,OAAOC,aAAa,CAAC,GAA6C;QACjE,OAAO,IAAI;IACb;IAEAa,QAAQN,EAAmB,EAAEe,OAA2C,EAAEC,QAA2B,EAAgC;QACnI,IAAI,OAAOhB,OAAO,YAAY,MAAM,IAAIiB,MAAM;QAC9C,IAAI,OAAOF,YAAY,YAAY;YACjCC,WAAWD;YACXA,UAAU,CAAC;QACb;QAEA,IAAI,OAAOC,aAAa,YAAY;YAClC,IAAI,IAAI,CAAClB,IAAI,EAAE;gBACbkB,SAAS,MAAM;gBACf;YACF;YACAD,UAAUA,WAAW,CAAC;YACtB,MAAMG,mBAAwC;gBAC5CC,MAAMnB;gBACNoB,WAAWL,QAAQK,SAAS,IAAI;gBAChCC,aAAaN,QAAQM,WAAW,IAAI;gBACpCC,OAAOP,QAAQO,KAAK,IAAIC;gBACxBC,OACET,QAAQS,KAAK,IACb,SAASC;oBACP,OAAO,MAAM,2BAA2B;gBAC1C;gBACFC,OAAO;gBACPC,SAAS;gBACTC,YAAY;oBACV,OAAO,CAAC,IAAI,CAAC9B,IAAI,IAAI,IAAI,CAACM,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACwB,MAAM,CAACxB,MAAM,GAAG,IAAI,CAACD,KAAK,CAACC,MAAM;gBACtF;YACF;YAEA,IAAIyB,YAAY5C,gBAAmBD,aAAgC,IAAI,GAAGiC,kBAAkB,CAACL;gBAC3F,IAAI,CAAC,IAAI,CAACkB,SAAS,EAAE,IAAI,CAACC,UAAU,CAACC,MAAM,CAACH;gBAC5CA,YAAY;gBACZf,UAAU;gBACV,MAAMjB,OAAO,CAAC,IAAI,CAACM,KAAK,CAACC,MAAM;gBAC/B,IAAI,AAACQ,CAAAA,OAAOf,IAAG,KAAM,CAAC,IAAI,CAACA,IAAI,EAAE,IAAI,CAACoC,GAAG,CAACrB;gBAC1C,OAAOG,SAASH,KAAK,IAAI,CAACf,IAAI,IAAIA;YACpC;YACA,IAAI,CAACkC,UAAU,CAACjC,IAAI,CAAC+B;YACrB,IAAI,CAACtB,KAAK;YACV;QACF;QAEA,OAAO,IAAI2B,QAAQ,CAACzB,SAASC,SAC3B,IAAI,CAACL,OAAO,CAACN,IAAIe,SAAS,CAACF,KAAaf;gBACtCe,MAAMF,OAAOE,OAAOH,QAAQZ;YAC9B;IAEJ;IAEAoC,IAAIrB,GAAW,EAAE;QACf,IAAI,IAAI,CAACf,IAAI,EAAE;QACf,IAAI,CAACA,IAAI,GAAG;QACZ,MAAO,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,EAAG,IAAI,CAAC2B,UAAU,CAACI,GAAG,GAAGvB,OAAO;QAChE,MAAO,IAAI,CAACwB,UAAU,CAAChC,MAAM,GAAG,EAAGQ,MAAM,IAAI,CAACwB,UAAU,CAACD,GAAG,GAAGvB,OAAO,IAAI,CAACwB,UAAU,CAACD,GAAG,GAAG,MAAM;YAAEtC,MAAM;YAAMwC,OAAO;QAAK;QAC5H,MAAO,IAAI,CAACT,MAAM,CAACxB,MAAM,GAAG,EAAGQ,MAAM,IAAI,CAACgB,MAAM,CAACO,GAAG,GAAGvB,OAAO,IAAI,CAACgB,MAAM,CAACO,GAAG,GAAG,MAAM;YAAEtC,MAAM;YAAMwC,OAAO;QAAK;QAChH,MAAO,IAAI,CAAClC,KAAK,CAACC,MAAM,GAAG,EAAG,IAAI,CAACD,KAAK,CAACgC,GAAG;IAC9C;IACAG,QAAQ1B,GAAW,EAAE;QACnB,IAAI,IAAI,CAACkB,SAAS,EAAE,MAAM,IAAId,MAAM;QACpC,IAAI,CAACc,SAAS,GAAG;QACjB,IAAI,CAACG,GAAG,CAACrB;IACX;IAEQL,QAAQ;QACd,IAAI,CAAC,IAAI,CAACV,IAAI,IAAI,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,IAAI,CAACwB,MAAM,CAACxB,MAAM,EAAE,IAAI,CAAC2B,UAAU,CAACQ,IAAI,GAAG,QAAQ,oBAAoB;QACpK,MAAO,IAAI,CAACpC,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACwB,MAAM,CAACxB,MAAM,GAAG,EAAG;YACtD,IAAI,CAACO,eAAe,CAAC,IAAI,CAACiB,MAAM,CAACO,GAAG;YACpC,IAAI,CAAC,IAAI,CAACtC,IAAI,IAAI,IAAI,CAACkC,UAAU,CAAC3B,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,KAAK,IAAI,CAACD,KAAK,CAACC,MAAM,GAAG,IAAI,CAACwB,MAAM,CAACxB,MAAM,EAAE,IAAI,CAAC2B,UAAU,CAACQ,IAAI,GAAG,QAAQ,oBAAoB;QACtK;IACF;IAEQ5B,gBAAgBI,QAA4B,EAAa;QAC/D,IAAI,IAAI,CAAClB,IAAI,EAAE;YACbkB,SAAS,MAAM;gBAAElB,MAAM;gBAAMwC,OAAO;YAAK;YACzC;QACF;QAEA,8BAA8B;QAC9B,IAAI,IAAI,CAAClC,KAAK,CAACC,MAAM,KAAK,GAAG;YAC3B,IAAI,CAACwB,MAAM,CAAC9B,IAAI,CAACiB;YACjB;QACF;QAEA,eAAe;QACf,MAAMP,OAAO,IAAI,CAACL,KAAK,CAACgC,GAAG;QAC3B,IAAI,CAACC,UAAU,CAACtC,IAAI,CAACiB;QACrBP,KAAK,IAAI,EAAE,CAACI,KAAaC;YACvB,IAAI,CAACuB,UAAU,CAACJ,MAAM,CAACjB;YAEvB,OAAO;YACP,IAAI,IAAI,CAAClB,IAAI,EACX,OAAOkB,SAAS,MAAM;gBACpBlB,MAAM;gBACNwC,OAAO;YACT;YAEF,aAAa;YACb,IAAIzB,OAAO7B,OAAOyD,YAAY,CAAC,IAAI,CAAC1B,OAAO,CAACS,KAAK,CAACX,MAAM,OAAOA,MAAM;YAErE,kBAAkB;YAClB,IAAIA,KAAKG,SAASH;iBACb,IAAI,CAACC,QAAQ,IAAI,CAACF,eAAe,CAACI;iBAClCA,SAAS,MAAMF;YAEpB,OAAO;YACP,IAAI,IAAI,CAACV,KAAK,CAACC,MAAM,KAAK,KAAK,IAAI,CAACgC,UAAU,CAAChC,MAAM,KAAK,KAAK,CAAC,IAAI,CAACP,IAAI,EAAE,IAAI,CAACoC,GAAG,IAAI,MAAM;QAC/F;IACF;IAlJA,YAAYnB,UAAwB,CAAC,CAAC,CAAE;QACtC,IAAI,CAACA,OAAO,GAAG;YAAE,GAAGA,OAAO;QAAC;QAC5B,IAAI,CAACA,OAAO,CAACS,KAAK,GAChBT,QAAQS,KAAK,IACb,SAASC,aAAaZ,GAAG;YACvB,OAAO,CAAC,CAACA,KAAK,iBAAiB;QACjC;QAEF,IAAI,CAACf,IAAI,GAAG;QACZ,IAAI,CAACM,KAAK,GAAG,EAAE;QACf,IAAI,CAACyB,MAAM,GAAG,EAAE;QAChB,IAAI,CAACG,UAAU,GAAG,IAAI5C;QACtB,IAAI,CAACiD,UAAU,GAAG,IAAIjD;IACxB;AAsIF;AA7JA,SAAqBQ,+BA6JpB"}

package.json

 {
   "name": "stack-base-iterator",
-  "version": "2.0.4",
+  "version": "2.0.5",
   "description": "Base iterator for values retrieved using a stack of async functions returning values",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

60943

0.57%

Lines of code

601

0.33%

No dependency changes