maximize-iterator
Advanced tools
@@ -19,7 +19,4 @@ "use strict"; | ||
| if (typeof each !== 'function') throw new Error('Missing each function'); | ||
| if (typeof options === 'function') { | ||
| callback = options; | ||
| options = {}; | ||
| } | ||
| options = options || {}; | ||
| callback = typeof options === 'function' ? options : callback; | ||
| options = typeof options === 'function' ? {} : options || {}; | ||
| if (typeof callback === 'function') { | ||
@@ -26,0 +23,0 @@ (0, _workerts.default)(iterator, each, options, callback); |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/maximize-iterator/src/maximizeIterator.ts"],"sourcesContent":["import type { Callback, EachFunction, ForEachOptions, Iterator } from './types.ts';\nimport worker from './worker.ts';\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: Iterator<T, TReturn, TNext>, each: EachFunction<T>, options?: ForEachOptions | Callback, callback?: Callback): void | Promise<void> {\n if (typeof each !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as Callback;\n options = {};\n }\n options = options || {};\n\n if (typeof callback === 'function') {\n worker(iterator, each, options, callback);\n return;\n }\n return new Promise((resolve, reject) => worker(iterator, each, options, (err) => (err ? reject(err) : resolve())));\n}\n"],"names":["maximizeIterator","iterator","each","options","callback","Error","worker","Promise","resolve","reject","err"],"mappings":";;;;+BAiBA;;;eAAwBA;;;+DAhBL;;;;;;AAgBJ,SAASA,iBAAwDC,QAAqC,EAAEC,IAAqB,EAAEC,OAAmC,EAAEC,QAAmB;IACpM,IAAI,OAAOF,SAAS,YAAY,MAAM,IAAIG,MAAM;IAChD,IAAI,OAAOF,YAAY,YAAY;QACjCC,WAAWD;QACXA,UAAU,CAAC;IACb;IACAA,UAAUA,WAAW,CAAC;IAEtB,IAAI,OAAOC,aAAa,YAAY;QAClCE,IAAAA,iBAAM,EAACL,UAAUC,MAAMC,SAASC;QAChC;IACF;IACA,OAAO,IAAIG,QAAQ,SAACC,SAASC;eAAWH,IAAAA,iBAAM,EAACL,UAAUC,MAAMC,SAAS,SAACO;mBAASA,MAAMD,OAAOC,OAAOF;;;AACxG"} | ||
| {"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/maximize-iterator/src/maximizeIterator.ts"],"sourcesContent":["import type { Callback, EachFunction, ForEachOptions, Iterator } from './types.ts';\nimport worker from './worker.ts';\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: Iterator<T, TReturn, TNext>, each: EachFunction<T>, options?: ForEachOptions | Callback, callback?: Callback): void | Promise<void> {\n if (typeof each !== 'function') throw new Error('Missing each function');\n callback = typeof options === 'function' ? options : callback;\n options = typeof options === 'function' ? {} : ((options || {}) as ForEachOptions);\n\n if (typeof callback === 'function') {\n worker(iterator, each, options, callback);\n return;\n }\n return new Promise((resolve, reject) => worker(iterator, each, options, (err) => (err ? reject(err) : resolve())));\n}\n"],"names":["maximizeIterator","iterator","each","options","callback","Error","worker","Promise","resolve","reject","err"],"mappings":";;;;+BAiBA;;;eAAwBA;;;+DAhBL;;;;;;AAgBJ,SAASA,iBAAwDC,QAAqC,EAAEC,IAAqB,EAAEC,OAAmC,EAAEC,QAAmB;IACpM,IAAI,OAAOF,SAAS,YAAY,MAAM,IAAIG,MAAM;IAChDD,WAAW,OAAOD,YAAY,aAAaA,UAAUC;IACrDD,UAAU,OAAOA,YAAY,aAAa,CAAC,IAAMA,WAAW,CAAC;IAE7D,IAAI,OAAOC,aAAa,YAAY;QAClCE,IAAAA,iBAAM,EAACL,UAAUC,MAAMC,SAASC;QAChC;IACF;IACA,OAAO,IAAIG,QAAQ,SAACC,SAASC;eAAWH,IAAAA,iBAAM,EAACL,UAAUC,MAAMC,SAAS,SAACO;mBAASA,MAAMD,OAAOC,OAAOF;;;AACxG"} |
| import worker from './worker.js'; | ||
| export default function maximizeIterator(iterator, each, options, callback) { | ||
| if (typeof each !== 'function') throw new Error('Missing each function'); | ||
| if (typeof options === 'function') { | ||
| callback = options; | ||
| options = {}; | ||
| } | ||
| options = options || {}; | ||
| callback = typeof options === 'function' ? options : callback; | ||
| options = typeof options === 'function' ? {} : options || {}; | ||
| if (typeof callback === 'function') { | ||
@@ -10,0 +7,0 @@ worker(iterator, each, options, callback); |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/maximize-iterator/src/maximizeIterator.ts"],"sourcesContent":["import type { Callback, EachFunction, ForEachOptions, Iterator } from './types.ts';\nimport worker from './worker.ts';\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: Iterator<T, TReturn, TNext>, each: EachFunction<T>, options?: ForEachOptions | Callback, callback?: Callback): void | Promise<void> {\n if (typeof each !== 'function') throw new Error('Missing each function');\n if (typeof options === 'function') {\n callback = options as Callback;\n options = {};\n }\n options = options || {};\n\n if (typeof callback === 'function') {\n worker(iterator, each, options, callback);\n return;\n }\n return new Promise((resolve, reject) => worker(iterator, each, options, (err) => (err ? reject(err) : resolve())));\n}\n"],"names":["worker","maximizeIterator","iterator","each","options","callback","Error","Promise","resolve","reject","err"],"mappings":"AACA,OAAOA,YAAY,cAAc;AAgBjC,eAAe,SAASC,iBAAwDC,QAAqC,EAAEC,IAAqB,EAAEC,OAAmC,EAAEC,QAAmB;IACpM,IAAI,OAAOF,SAAS,YAAY,MAAM,IAAIG,MAAM;IAChD,IAAI,OAAOF,YAAY,YAAY;QACjCC,WAAWD;QACXA,UAAU,CAAC;IACb;IACAA,UAAUA,WAAW,CAAC;IAEtB,IAAI,OAAOC,aAAa,YAAY;QAClCL,OAAOE,UAAUC,MAAMC,SAASC;QAChC;IACF;IACA,OAAO,IAAIE,QAAQ,CAACC,SAASC,SAAWT,OAAOE,UAAUC,MAAMC,SAAS,CAACM,MAASA,MAAMD,OAAOC,OAAOF;AACxG"} | ||
| {"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/maximize-iterator/src/maximizeIterator.ts"],"sourcesContent":["import type { Callback, EachFunction, ForEachOptions, Iterator } from './types.ts';\nimport worker from './worker.ts';\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, callback: Callback): void;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions, callback: Callback): void;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterable<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>): Promise<void>;\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterableIterator<T, TReturn, TNext>, each: EachFunction<T>, options: ForEachOptions): Promise<void>;\n\nexport default function maximizeIterator<T, TReturn = unknown, TNext = unknown>(iterator: Iterator<T, TReturn, TNext>, each: EachFunction<T>, options?: ForEachOptions | Callback, callback?: Callback): void | Promise<void> {\n if (typeof each !== 'function') throw new Error('Missing each function');\n callback = typeof options === 'function' ? options : callback;\n options = typeof options === 'function' ? {} : ((options || {}) as ForEachOptions);\n\n if (typeof callback === 'function') {\n worker(iterator, each, options, callback);\n return;\n }\n return new Promise((resolve, reject) => worker(iterator, each, options, (err) => (err ? reject(err) : resolve())));\n}\n"],"names":["worker","maximizeIterator","iterator","each","options","callback","Error","Promise","resolve","reject","err"],"mappings":"AACA,OAAOA,YAAY,cAAc;AAgBjC,eAAe,SAASC,iBAAwDC,QAAqC,EAAEC,IAAqB,EAAEC,OAAmC,EAAEC,QAAmB;IACpM,IAAI,OAAOF,SAAS,YAAY,MAAM,IAAIG,MAAM;IAChDD,WAAW,OAAOD,YAAY,aAAaA,UAAUC;IACrDD,UAAU,OAAOA,YAAY,aAAa,CAAC,IAAMA,WAAW,CAAC;IAE7D,IAAI,OAAOC,aAAa,YAAY;QAClCL,OAAOE,UAAUC,MAAMC,SAASC;QAChC;IACF;IACA,OAAO,IAAIE,QAAQ,CAACC,SAASC,SAAWT,OAAOE,UAAUC,MAAMC,SAAS,CAACM,MAASA,MAAMD,OAAOC,OAAOF;AACxG"} |
+1
-1
| { | ||
| "name": "maximize-iterator", | ||
| "version": "5.0.2", | ||
| "version": "5.0.4", | ||
| "description": "Maximize the parallel calls of an iterator supporting asyncIterator interface", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
49217
0.13%368
-1.6%