iterator-next-callback
Advanced tools
| 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"} |
@@ -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); |
+4
-4
| { | ||
| "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"} |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
12472
5.05%19
26.67%107
22.99%1
Infinity%