You're Invited:Meet the Socket Team at RSAC and BSidesSF 2026, March 23–26.RSVP
Socket
Book a DemoSign in
Socket

maximize-iterator

Package Overview
Dependencies
Maintainers
1
Versions
66
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

maximize-iterator - npm Package Compare versions

Comparing version
5.0.2
to
5.0.4
+2
-5
dist/cjs/maximizeIterator.js

@@ -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"}
{
"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": [