iterator-next-callback - npm Package Compare versions

Comparing version 1.3.16 to 2.0.0

dist/cjs/index.d.cts

@@ -1,4 +0,3 @@
-import type { CallbackIterator } from './types.js';
+import type { IteratorCallback } from './types.js';
 export * from './types.js';
-export default function iteratorNextCallback<T>(iterator: AsyncIterable<T>): undefined;
-export default function iteratorNextCallback<T>(iterator: CallbackIterator<T>): undefined;
+export default function iteratorNextCallback<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext> | AsyncIterable<T, TReturn, TNext> | AsyncIterableIterator<T, TReturn, TNext>): IteratorCallback<T>;

dist/cjs/index.d.ts

@@ -1,4 +0,3 @@
-import type { CallbackIterator } from './types.js';
+import type { IteratorCallback } from './types.js';
 export * from './types.js';
-export default function iteratorNextCallback<T>(iterator: AsyncIterable<T>): undefined;
-export default function iteratorNextCallback<T>(iterator: CallbackIterator<T>): undefined;
+export default function iteratorNextCallback<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext> | AsyncIterable<T, TReturn, TNext> | AsyncIterableIterator<T, TReturn, TNext>): IteratorCallback<T>;

dist/cjs/index.js

@@ -33,5 +33,5 @@ "use strict";
     if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
-        return function nextAsyncIterator(callback) {
+        return function nextAsyncIterable(callback) {
             iterator[Symbol.asyncIterator]().next().then(function(result) {
-                callback(null, result.done ? null : result.value);
+                callback(null, result);
             }).catch(function(err) {
@@ -42,6 +42,4 @@ callback(err);
     }
-    return function next(callback) {
-        var result = iterator.next(callback);
-        if (!result) return; // callback based callback
-        // async iterator
+    return function AsyncIterator(callback) {
+        var result = iterator.next();
         if ((0, _ispromise.default)(result)) {
@@ -54,3 +52,3 @@ result.then(function(result) {
         } else {
-            callback(null, result.value);
+            callback(null, result);
         }
@@ -57,0 +55,0 @@ };

dist/cjs/index.js.map

@@ -1,1 +0,1 @@
-{"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, CallbackIteratorNext, TNext } from './types.js';\n\nexport * from './types.js';\n\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T>): undefined;\nexport default function iteratorNextCallback<T>(iterator: CallbackIterator<T>): undefined;\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): CallbackIteratorNext<T> | undefined {\n  if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n    return function nextAsyncIterator(callback: CallbackIteratorCallback<T>): undefined {\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>): 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":";;;;+BAQA;;;eAAwBA;;;gEARF;qBAIR;;;;;;;;;;;;;;;;;;;AAIC,SAASA,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAqC;YACrEJ,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"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\nimport type { Callback, IteratorCallback } from './types.js';\n\nexport * from './types.js';\n\nexport default function iteratorNextCallback<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext> | AsyncIterable<T, TReturn, TNext> | AsyncIterableIterator<T, TReturn, TNext>): IteratorCallback<T> {\n  if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n    return function nextAsyncIterable(callback: Callback<T>): undefined {\n      iterator[Symbol.asyncIterator]()\n        .next()\n        .then((result) => {\n          callback(null, result);\n        })\n        .catch((err) => {\n          callback(err);\n        });\n    };\n  }\n\n  return function AsyncIterator(callback: Callback<T>): undefined {\n    const result = (iterator as AsyncIterator<T, TReturn>).next();\n    if (isPromise(result)) {\n      result\n        .then((result) => {\n          callback(null, result);\n        })\n        .catch((err) => {\n          callback(err);\n        });\n    } else {\n      callback(null, result);\n    }\n  };\n}\n"],"names":["iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterable","callback","next","then","result","catch","err","AsyncIterator","isPromise"],"mappings":";;;;+BAKA;;;eAAwBA;;;gEALF;qBAGR;;;;;;;;;;;;;;;;;;;AAEC,SAASA,qBAA4DC,QAAwH;IAC1M,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAqB;YACrDJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG;YACjB,GACCC,KAAK,CAAC,SAACC;gBACNL,SAASK;YACX;QACJ;IACF;IAEA,OAAO,SAASC,cAAcN,QAAqB;QACjD,IAAMG,SAAS,AAACP,SAAuCK,IAAI;QAC3D,IAAIM,IAAAA,kBAAS,EAACJ,SAAS;YACrBA,OACGD,IAAI,CAAC,SAACC;gBACLH,SAAS,MAAMG;YACjB,GACCC,KAAK,CAAC,SAACC;gBACNL,SAASK;YACX;QACJ,OAAO;YACLL,SAAS,MAAMG;QACjB;IACF;AACF"}

dist/cjs/types.d.cts

@@ -1,8 +0,2 @@
-export interface TNext<T> {
-    value: T;
-}
-export type CallbackIteratorCallback<T> = (error?: Error, value?: T) => void;
-export type CallbackIteratorNext<T> = (callback?: CallbackIteratorCallback<T>) => undefined;
-export interface CallbackIterator<T> {
-    next(callback?: CallbackIteratorCallback<T>): undefined;
-}
+export type Callback<T, TReturn = unknown> = (error?: Error, result?: IteratorResult<T, TReturn>) => void;
+export type IteratorCallback<T> = (callback?: Callback<T>) => undefined;

dist/cjs/types.d.ts

@@ -1,8 +0,2 @@
-export interface TNext<T> {
-    value: T;
-}
-export type CallbackIteratorCallback<T> = (error?: Error, value?: T) => void;
-export type CallbackIteratorNext<T> = (callback?: CallbackIteratorCallback<T>) => undefined;
-export interface CallbackIterator<T> {
-    next(callback?: CallbackIteratorCallback<T>): undefined;
-}
+export type Callback<T, TReturn = unknown> = (error?: Error, result?: IteratorResult<T, TReturn>) => void;
+export type IteratorCallback<T> = (callback?: Callback<T>) => undefined;

dist/esm/index.d.ts

@@ -1,4 +0,3 @@
-import type { CallbackIterator } from './types.js';
+import type { IteratorCallback } from './types.js';
 export * from './types.js';
-export default function iteratorNextCallback<T>(iterator: AsyncIterable<T>): undefined;
-export default function iteratorNextCallback<T>(iterator: CallbackIterator<T>): undefined;
+export default function iteratorNextCallback<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext> | AsyncIterable<T, TReturn, TNext> | AsyncIterableIterator<T, TReturn, TNext>): IteratorCallback<T>;

dist/esm/index.js

@@ -5,5 +5,5 @@ import isPromise from 'is-promise';
     if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {
-        return function nextAsyncIterator(callback) {
+        return function nextAsyncIterable(callback) {
             iterator[Symbol.asyncIterator]().next().then((result)=>{
-                callback(null, result.done ? null : result.value);
+                callback(null, result);
             }).catch((err)=>{
@@ -14,6 +14,4 @@ callback(err);
     }
-    return function next(callback) {
-        const result = iterator.next(callback);
-        if (!result) return; // callback based callback
-        // async iterator
+    return function AsyncIterator(callback) {
+        const result = iterator.next();
         if (isPromise(result)) {
@@ -26,5 +24,5 @@ result.then((result)=>{
         } else {
-            callback(null, result.value);
+            callback(null, result);
         }
     };
 }

dist/esm/index.js.map

@@ -1,1 +0,1 @@
-{"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, CallbackIteratorNext, TNext } from './types.js';\n\nexport * from './types.js';\n\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T>): undefined;\nexport default function iteratorNextCallback<T>(iterator: CallbackIterator<T>): undefined;\nexport default function iteratorNextCallback<T>(iterator: AsyncIterable<T> | CallbackIterator<T>): CallbackIteratorNext<T> | undefined {\n  if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n    return function nextAsyncIterator(callback: CallbackIteratorCallback<T>): undefined {\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>): 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;AAI3B,eAAe,SAASC,qBAAwBC,QAAgD;IAC9F,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAqC;YACrEJ,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"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/index.ts"],"sourcesContent":["import isPromise from 'is-promise';\nimport type { Callback, IteratorCallback } from './types.js';\n\nexport * from './types.js';\n\nexport default function iteratorNextCallback<T, TReturn = unknown, TNext = unknown>(iterator: AsyncIterator<T, TReturn, TNext> | AsyncIterable<T, TReturn, TNext> | AsyncIterableIterator<T, TReturn, TNext>): IteratorCallback<T> {\n  if (typeof Symbol !== 'undefined' && Symbol.asyncIterator && iterator[Symbol.asyncIterator]) {\n    return function nextAsyncIterable(callback: Callback<T>): undefined {\n      iterator[Symbol.asyncIterator]()\n        .next()\n        .then((result) => {\n          callback(null, result);\n        })\n        .catch((err) => {\n          callback(err);\n        });\n    };\n  }\n\n  return function AsyncIterator(callback: Callback<T>): undefined {\n    const result = (iterator as AsyncIterator<T, TReturn>).next();\n    if (isPromise(result)) {\n      result\n        .then((result) => {\n          callback(null, result);\n        })\n        .catch((err) => {\n          callback(err);\n        });\n    } else {\n      callback(null, result);\n    }\n  };\n}\n"],"names":["isPromise","iteratorNextCallback","iterator","Symbol","asyncIterator","nextAsyncIterable","callback","next","then","result","catch","err","AsyncIterator"],"mappings":"AAAA,OAAOA,eAAe,aAAa;AAGnC,cAAc,aAAa;AAE3B,eAAe,SAASC,qBAA4DC,QAAwH;IAC1M,IAAI,OAAOC,WAAW,eAAeA,OAAOC,aAAa,IAAIF,QAAQ,CAACC,OAAOC,aAAa,CAAC,EAAE;QAC3F,OAAO,SAASC,kBAAkBC,QAAqB;YACrDJ,QAAQ,CAACC,OAAOC,aAAa,CAAC,GAC3BG,IAAI,GACJC,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG;YACjB,GACCC,KAAK,CAAC,CAACC;gBACNL,SAASK;YACX;QACJ;IACF;IAEA,OAAO,SAASC,cAAcN,QAAqB;QACjD,MAAMG,SAAS,AAACP,SAAuCK,IAAI;QAC3D,IAAIP,UAAUS,SAAS;YACrBA,OACGD,IAAI,CAAC,CAACC;gBACLH,SAAS,MAAMG;YACjB,GACCC,KAAK,CAAC,CAACC;gBACNL,SAASK;YACX;QACJ,OAAO;YACLL,SAAS,MAAMG;QACjB;IACF;AACF"}

dist/esm/types.d.ts

@@ -1,8 +0,2 @@
-export interface TNext<T> {
-    value: T;
-}
-export type CallbackIteratorCallback<T> = (error?: Error, value?: T) => void;
-export type CallbackIteratorNext<T> = (callback?: CallbackIteratorCallback<T>) => undefined;
-export interface CallbackIterator<T> {
-    next(callback?: CallbackIteratorCallback<T>): undefined;
-}
+export type Callback<T, TReturn = unknown> = (error?: Error, result?: IteratorResult<T, TReturn>) => void;
+export type IteratorCallback<T> = (callback?: Callback<T>) => undefined;

dist/esm/types.js.map

@@ -1,1 +0,1 @@
-{"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> = (error?: Error, value?: T) => void;\nexport type CallbackIteratorNext<T> = (callback?: CallbackIteratorCallback<T>) => undefined;\n\nexport interface CallbackIterator<T> {\n  next(callback?: CallbackIteratorCallback<T>): undefined;\n}\n"],"names":[],"mappings":"AAOA,WAEC"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/iterator-next-callback/src/types.ts"],"sourcesContent":["export type Callback<T, TReturn = unknown> = (error?: Error, result?: IteratorResult<T, TReturn>) => void;\nexport type IteratorCallback<T> = (callback?: Callback<T>) => undefined;\n"],"names":[],"mappings":"AACA,WAAwE"}

package.json

 {
   "name": "iterator-next-callback",
-  "version": "1.3.16",
+  "version": "2.0.0",
   "description": "Calls async iterator next using a callback format",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Worsened metrics

Total package byte prevSize

11700

-11.42%

Lines of code

93

-16.22%

No dependency changes