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

iterator-next-callback

Package Overview
Dependencies
Maintainers
1
Versions
35
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

iterator-next-callback - npm Package Compare versions

Comparing version
1.3.14
to
1.3.15
+3
dist/cjs/index.d.ts
import type { CallbackIterator, CallbackIteratorCallback } from './types.js';
export * from './types.js';
export default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): ((callback: any) => void) | ((callback?: CallbackIteratorCallback<T>) => Promise<T> | undefined);
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
Object.defineProperty(exports, "default", {
enumerable: true,
get: function() {
return iteratorNextCallback;
}
});
var _ispromise = /*#__PURE__*/ _interop_require_default(require("is-promise"));
_export_star(require("./types.js"), exports);
function _export_star(from, to) {
Object.keys(from).forEach(function(k) {
if (k !== "default" && !Object.prototype.hasOwnProperty.call(to, k)) {
Object.defineProperty(to, k, {
enumerable: true,
get: function() {
return from[k];
}
});
}
});
return from;
}
function _interop_require_default(obj) {
return obj && obj.__esModule ? obj : {
default: obj
};
}
function iteratorNextCallback(iterator) {
if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
return function nextAsyncIterator(callback) {
iterator[Symbol.asyncIterator]().next().then(function(result) {
callback(null, result.done ? null : result.value);
}).catch(function(err) {
callback(err);
});
};
}
return function next(callback) {
var result = iterator.next(callback);
if (!result) return; // callback based callback
// async iterator
if ((0, _ispromise.default)(result)) {
result.then(function(result) {
callback(null, result);
}).catch(function(err) {
callback(err);
});
} else {
callback(null, result.value);
}
};
}
/* CJS INTEROP */ if (exports.__esModule && exports.default) { try { Object.defineProperty(exports.default, '__esModule', { value: true }); for (var key in exports) { exports.default[key] = exports[key]; } } catch (_) {}; module.exports = exports.default; }
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\n\nimport type { CallbackIterator, CallbackIteratorCallback, TNext } from './types.js';\n\nexport * from './types.js';\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>) {\n if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n return function nextAsyncIterator(callback) {\n iterator[Symbol.asyncIterator]()\n .next()\n .then((result) => {\n callback(null, result.done ? null : result.value);\n })\n .catch((err) => {\n callback(err);\n });\n };\n }\n return function next(callback?: CallbackIteratorCallback<T>): Promise<T> | undefined {\n const result = (iterator as CallbackIterator<T>).next(callback);\n if (!result) return; // callback based callback\n\n // async iterator\n if (isPromise(result)) {\n (result as Promise<T>)\n .then((result) => {\n callback(null, result);\n })\n .catch((err) => {\n callback(err);\n });\n }\n // synchronous iterator\n else {\n callback(null, (result as TNext<T>).value);\n }\n };\n}\n"],"names":["iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterator","callback","next","then","result","done","value","catch","err","isPromise"],"mappings":";;;;+BAKA;;;eAAwBA;;;gEALF;qBAIR;;;;;;;;;;;;;;;;;;;AACC,SAASA,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAQ;YACxCJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG,OAAOC,IAAI,GAAG,OAAOD,OAAOE,KAAK;YAClD,GACCC,KAAK,CAAC,SAACC;gBACNP,SAASO;YACX;QACJ;IACF;IACA,OAAO,SAASN,KAAKD,QAAsC;QACzD,IAAMG,SAAS,AAACP,SAAiCK,IAAI,CAACD;QACtD,IAAI,CAACG,QAAQ,QAAQ,0BAA0B;QAE/C,iBAAiB;QACjB,IAAIK,IAAAA,kBAAS,EAACL,SAAS;YACpBA,OACED,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG;YACjB,GACCG,KAAK,CAAC,SAACC;gBACNP,SAASO;YACX;QACJ,OAEK;YACHP,SAAS,MAAM,AAACG,OAAoBE,KAAK;QAC3C;IACF;AACF"}
{ "type": "commonjs" }
export interface TNext<T> {
value: T;
}
export type CallbackIteratorCallback<T> = (err?: Error, value?: T) => void;
export interface CallbackIterator<T> {
next(callback?: CallbackIteratorCallback<T>): undefined | Promise<T>;
}
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
/* CJS INTEROP */ if (exports.__esModule && exports.default) { try { Object.defineProperty(exports.default, '__esModule', { value: true }); for (var key in exports) { exports.default[key] = exports[key]; } } catch (_) {}; module.exports = exports.default; }
{"version":3,"sources":[],"names":[],"mappings":""}
import type { CallbackIterator, CallbackIteratorCallback } from './types.js';
export * from './types.js';
export default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): ((callback: any) => void) | ((callback?: CallbackIteratorCallback<T>) => Promise<T> | undefined);
import isPromise from 'is-promise';
export * from './types.js';
export default function iteratorNextCallback(iterator) {
if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
return function nextAsyncIterator(callback) {
iterator[Symbol.asyncIterator]().next().then((result)=>{
callback(null, result.done ? null : result.value);
}).catch((err)=>{
callback(err);
});
};
}
return function next(callback) {
const result = iterator.next(callback);
if (!result) return; // callback based callback
// async iterator
if (isPromise(result)) {
result.then((result)=>{
callback(null, result);
}).catch((err)=>{
callback(err);
});
} else {
callback(null, result.value);
}
};
}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\n\nimport type { CallbackIterator, CallbackIteratorCallback, TNext } from './types.js';\n\nexport * from './types.js';\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>) {\n if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n return function nextAsyncIterator(callback) {\n iterator[Symbol.asyncIterator]()\n .next()\n .then((result) => {\n callback(null, result.done ? null : result.value);\n })\n .catch((err) => {\n callback(err);\n });\n };\n }\n return function next(callback?: CallbackIteratorCallback<T>): Promise<T> | undefined {\n const result = (iterator as CallbackIterator<T>).next(callback);\n if (!result) return; // callback based callback\n\n // async iterator\n if (isPromise(result)) {\n (result as Promise<T>)\n .then((result) => {\n callback(null, result);\n })\n .catch((err) => {\n callback(err);\n });\n }\n // synchronous iterator\n else {\n callback(null, (result as TNext<T>).value);\n }\n };\n}\n"],"names":["isPromise","iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterator","callback","next","then","result","done","value","catch","err"],"mappings":"AAAA,OAAOA,eAAe,aAAa;AAInC,cAAc,aAAa;AAC3B,eAAe,SAASC,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAQ;YACxCJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG,OAAOC,IAAI,GAAG,OAAOD,OAAOE,KAAK;YAClD,GACCC,KAAK,CAAC,CAACC;gBACNP,SAASO;YACX;QACJ;IACF;IACA,OAAO,SAASN,KAAKD,QAAsC;QACzD,MAAMG,SAAS,AAACP,SAAiCK,IAAI,CAACD;QACtD,IAAI,CAACG,QAAQ,QAAQ,0BAA0B;QAE/C,iBAAiB;QACjB,IAAIT,UAAUS,SAAS;YACpBA,OACED,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG;YACjB,GACCG,KAAK,CAAC,CAACC;gBACNP,SAASO;YACX;QACJ,OAEK;YACHP,SAAS,MAAM,AAACG,OAAoBE,KAAK;QAC3C;IACF;AACF"}
{ "type": "module" }
export interface TNext<T> {
value: T;
}
export type CallbackIteratorCallback<T> = (err?: Error, value?: T) => void;
export interface CallbackIterator<T> {
next(callback?: CallbackIteratorCallback<T>): undefined | Promise<T>;
}
export { };
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/types.ts"],"sourcesContent":["export interface TNext<T> {\n value: T;\n}\n\nexport type CallbackIteratorCallback<T> = (err?: Error, value?: T) => void;\n\nexport interface CallbackIterator<T> {\n next(callback?: CallbackIteratorCallback<T>): undefined | Promise<T>;\n}\n"],"names":[],"mappings":"AAMA,WAEC"}
+2
-2

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

import type { CallbackIterator, CallbackIteratorCallback } from './types';
export * from './types';
import type { CallbackIterator, CallbackIteratorCallback } from './types.js';
export * from './types.js';
export default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): ((callback: any) => void) | ((callback?: CallbackIteratorCallback<T>) => Promise<T> | undefined);
{
"name": "iterator-next-callback",
"version": "1.3.14",
"version": "1.3.15",
"description": "Calls async iterator next using a callback format",

@@ -22,8 +22,8 @@ "keywords": [

".": {
"import": "./dist/esm/index.mjs",
"require": "./dist/cjs/index.cjs"
"import": "./dist/esm/index.js",
"require": "./dist/cjs/index.js"
},
"./package.json": "./package.json"
},
"main": "dist/cjs/index.cjs",
"main": "dist/cjs/index.js",
"types": "dist/cjs/index.d.cts",

@@ -30,0 +30,0 @@ "files": [

"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
Object.defineProperty(exports, "default", {
enumerable: true,
get: function() {
return iteratorNextCallback;
}
});
var _ispromise = /*#__PURE__*/ _interop_require_default(require("is-promise"));
_export_star(require("./types.cjs"), exports);
function _export_star(from, to) {
Object.keys(from).forEach(function(k) {
if (k !== "default" && !Object.prototype.hasOwnProperty.call(to, k)) {
Object.defineProperty(to, k, {
enumerable: true,
get: function() {
return from[k];
}
});
}
});
return from;
}
function _interop_require_default(obj) {
return obj && obj.__esModule ? obj : {
default: obj
};
}
function iteratorNextCallback(iterator) {
if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
return function nextAsyncIterator(callback) {
iterator[Symbol.asyncIterator]().next().then(function(result) {
callback(null, result.done ? null : result.value);
}).catch(function(err) {
callback(err);
});
};
}
return function next(callback) {
var result = iterator.next(callback);
if (!result) return; // callback based callback
// async iterator
if ((0, _ispromise.default)(result)) {
result.then(function(result) {
callback(null, result);
}).catch(function(err) {
callback(err);
});
} else {
callback(null, result.value);
}
};
}
/* CJS INTEROP */ if (exports.__esModule && exports.default) { try { Object.defineProperty(exports.default, '__esModule', { value: true }); for (var key in exports) { exports.default[key] = exports[key]; } } catch (_) {}; module.exports = exports.default; }
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\n\nimport type { CallbackIterator, CallbackIteratorCallback, TNext } from './types';\n\nexport * from './types';\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>) {\n if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n return function nextAsyncIterator(callback) {\n iterator[Symbol.asyncIterator]()\n .next()\n .then((result) => {\n callback(null, result.done ? null : result.value);\n })\n .catch((err) => {\n callback(err);\n });\n };\n }\n return function next(callback?: CallbackIteratorCallback<T>): Promise<T> | undefined {\n const result = (iterator as CallbackIterator<T>).next(callback);\n if (!result) return; // callback based callback\n\n // async iterator\n if (isPromise(result)) {\n (result as Promise<T>)\n .then((result) => {\n callback(null, result);\n })\n .catch((err) => {\n callback(err);\n });\n }\n // synchronous iterator\n else {\n callback(null, (result as TNext<T>).value);\n }\n };\n}\n"],"names":["iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterator","callback","next","then","result","done","value","catch","err","isPromise"],"mappings":";;;;+BAKA;;;eAAwBA;;;gEALF;qBAIR;;;;;;;;;;;;;;;;;;;AACC,SAASA,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAQ;YACxCJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG,OAAOC,IAAI,GAAG,OAAOD,OAAOE,KAAK;YAClD,GACCC,KAAK,CAAC,SAACC;gBACNP,SAASO;YACX;QACJ;IACF;IACA,OAAO,SAASN,KAAKD,QAAsC;QACzD,IAAMG,SAAS,AAACP,SAAiCK,IAAI,CAACD;QACtD,IAAI,CAACG,QAAQ,QAAQ,0BAA0B;QAE/C,iBAAiB;QACjB,IAAIK,IAAAA,kBAAS,EAACL,SAAS;YACpBA,OACED,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG;YACjB,GACCG,KAAK,CAAC,SAACC;gBACNP,SAASO;YACX;QACJ,OAEK;YACHP,SAAS,MAAM,AAACG,OAAoBE,KAAK;QAC3C;IACF;AACF"}
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
/* CJS INTEROP */ if (exports.__esModule && exports.default) { try { Object.defineProperty(exports.default, '__esModule', { value: true }); for (var key in exports) { exports.default[key] = exports[key]; } } catch (_) {}; module.exports = exports.default; }
{"version":3,"sources":[],"names":[],"mappings":""}
import type { CallbackIterator, CallbackIteratorCallback } from './types';
export * from './types';
export default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): ((callback: any) => void) | ((callback?: CallbackIteratorCallback<T>) => Promise<T> | undefined);
import isPromise from 'is-promise';
export * from './types.mjs';
export default function iteratorNextCallback(iterator) {
if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
return function nextAsyncIterator(callback) {
iterator[Symbol.asyncIterator]().next().then((result)=>{
callback(null, result.done ? null : result.value);
}).catch((err)=>{
callback(err);
});
};
}
return function next(callback) {
const result = iterator.next(callback);
if (!result) return; // callback based callback
// async iterator
if (isPromise(result)) {
result.then((result)=>{
callback(null, result);
}).catch((err)=>{
callback(err);
});
} else {
callback(null, result.value);
}
};
}
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\n\nimport type { CallbackIterator, CallbackIteratorCallback, TNext } from './types';\n\nexport * from './types';\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>) {\n if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n return function nextAsyncIterator(callback) {\n iterator[Symbol.asyncIterator]()\n .next()\n .then((result) => {\n callback(null, result.done ? null : result.value);\n })\n .catch((err) => {\n callback(err);\n });\n };\n }\n return function next(callback?: CallbackIteratorCallback<T>): Promise<T> | undefined {\n const result = (iterator as CallbackIterator<T>).next(callback);\n if (!result) return; // callback based callback\n\n // async iterator\n if (isPromise(result)) {\n (result as Promise<T>)\n .then((result) => {\n callback(null, result);\n })\n .catch((err) => {\n callback(err);\n });\n }\n // synchronous iterator\n else {\n callback(null, (result as TNext<T>).value);\n }\n };\n}\n"],"names":["isPromise","iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterator","callback","next","then","result","done","value","catch","err"],"mappings":"AAAA,OAAOA,eAAe,aAAa;AAInC,cAAc,UAAU;AACxB,eAAe,SAASC,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAQ;YACxCJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG,OAAOC,IAAI,GAAG,OAAOD,OAAOE,KAAK;YAClD,GACCC,KAAK,CAAC,CAACC;gBACNP,SAASO;YACX;QACJ;IACF;IACA,OAAO,SAASN,KAAKD,QAAsC;QACzD,MAAMG,SAAS,AAACP,SAAiCK,IAAI,CAACD;QACtD,IAAI,CAACG,QAAQ,QAAQ,0BAA0B;QAE/C,iBAAiB;QACjB,IAAIT,UAAUS,SAAS;YACpBA,OACED,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG;YACjB,GACCG,KAAK,CAAC,CAACC;gBACNP,SAASO;YACX;QACJ,OAEK;YACHP,SAAS,MAAM,AAACG,OAAoBE,KAAK;QAC3C;IACF;AACF"}
export interface TNext<T> {
value: T;
}
export type CallbackIteratorCallback<T> = (err?: Error, value?: T) => void;
export interface CallbackIterator<T> {
next(callback?: CallbackIteratorCallback<T>): undefined | Promise<T>;
}
export { };
{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/types.ts"],"sourcesContent":["export interface TNext<T> {\n value: T;\n}\n\nexport type CallbackIteratorCallback<T> = (err?: Error, value?: T) => void;\n\nexport interface CallbackIterator<T> {\n next(callback?: CallbackIteratorCallback<T>): undefined | Promise<T>;\n}\n"],"names":[],"mappings":"AAMA,WAEC"}