@n1ru4l/push-pull-async-iterable-iterator - npm Package Compare versions

Comparing version 2.1.3 to 2.1.4

dist/push-pull-async-iterable-iterator.cjs.development.js

@@ -38,2 +38,6 @@ 'use strict';
         }
+
+        if (result !== SYMBOL_NEW_VALUE) {
+          throw result;
+        }
       }
@@ -65,6 +69,6 @@ }
 
-  asyncIterableIterator.throw = (...args) => {
+  asyncIterableIterator.throw = err => {
     isRunning = false;
-    finishedD.resolve(SYMBOL_FINISHED);
-    return originalThrow(...args);
+    finishedD.resolve(err);
+    return originalThrow(err);
   };
@@ -71,0 +75,0 @@

dist/push-pull-async-iterable-iterator.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";function e(){const e={};return e.promise=new Promise((r,t)=>{e.resolve=r,e.reject=t}),e}const r=Symbol(),t=Symbol();function o(){let o=!0;const n=[];let s=e(),a=e();const c=async function*(){for(;;)if(n.length>0)yield n.shift();else if(await Promise.race([s.promise,a.promise])===r)break}(),l=c.return.bind(c);c.return=(...e)=>(o=!1,a.resolve(r),l(...e));const u=c.throw.bind(c);return c.throw=(...e)=>(o=!1,a.resolve(r),u(...e)),{pushValue:function(r){!1!==o&&(n.push(r),s.resolve(t),s=e())},asyncIterableIterator:c}}exports.applyAsyncIterableIteratorToSink=function(e,r){return(async()=>{try{for await(const t of e)r.next(t);r.complete()}catch(e){r.error(e)}})(),()=>{null==e.return||e.return()}},exports.isAsyncIterable=function(e){return"object"==typeof e&&null!==e&&("AsyncGenerator"===e[Symbol.toStringTag]||Symbol.asyncIterator&&Symbol.asyncIterator in e)},exports.makeAsyncIterableIteratorFromSink=e=>{const{pushValue:r,asyncIterableIterator:t}=o(),n=e({next:e=>{r(e)},complete:()=>{t.return()},error:e=>{t.throw(e)}}),s=t.return;let a=void 0;return t.return=()=>(void 0===a&&(n(),a=s()),a),t},exports.makePushPullAsyncIterableIterator=o;
+"use strict";function r(){const r={};return r.promise=new Promise((e,t)=>{r.resolve=e,r.reject=t}),r}const e=Symbol(),t=Symbol();function o(){let o=!0;const n=[];let s=r(),a=r();const c=async function*(){for(;;)if(n.length>0)yield n.shift();else{const r=await Promise.race([s.promise,a.promise]);if(r===e)break;if(r!==t)throw r}}(),l=c.return.bind(c);c.return=(...r)=>(o=!1,a.resolve(e),l(...r));const i=c.throw.bind(c);return c.throw=r=>(o=!1,a.resolve(r),i(r)),{pushValue:function(e){!1!==o&&(n.push(e),s.resolve(t),s=r())},asyncIterableIterator:c}}exports.applyAsyncIterableIteratorToSink=function(r,e){return(async()=>{try{for await(const t of r)e.next(t);e.complete()}catch(r){e.error(r)}})(),()=>{null==r.return||r.return()}},exports.isAsyncIterable=function(r){return"object"==typeof r&&null!==r&&("AsyncGenerator"===r[Symbol.toStringTag]||Symbol.asyncIterator&&Symbol.asyncIterator in r)},exports.makeAsyncIterableIteratorFromSink=r=>{const{pushValue:e,asyncIterableIterator:t}=o(),n=r({next:r=>{e(r)},complete:()=>{t.return()},error:r=>{t.throw(r)}}),s=t.return;let a=void 0;return t.return=()=>(void 0===a&&(n(),a=s()),a),t},exports.makePushPullAsyncIterableIterator=o;
 //# sourceMappingURL=push-pull-async-iterable-iterator.cjs.production.min.js.map

package.json

 {
-  "version": "2.1.3",
+  "version": "2.1.4",
   "license": "MIT",
@@ -4,0 +4,0 @@ "main": "dist/index.js",

src/makePushPullAsyncIterableIterator.ts

@@ -40,3 +40,3 @@ type Deferred<T> = {
   let newValueD = createDeferred<typeof SYMBOL_NEW_VALUE>();
-  let finishedD = createDeferred<typeof SYMBOL_FINISHED>();
+  let finishedD = createDeferred<typeof SYMBOL_FINISHED | any>();
 
@@ -58,2 +58,5 @@ const asyncIterableIterator = (async function* PushPullAsyncIterableIterator(): AsyncIterableIterator<
         }
+        if (result !== SYMBOL_NEW_VALUE) {
+          throw result;
+        }
       }
@@ -90,6 +93,6 @@ }
   );
-  asyncIterableIterator.throw = (...args): Promise<IteratorResult<T, void>> => {
+  asyncIterableIterator.throw = (err): Promise<IteratorResult<T, void>> => {
     isRunning = false;
-    finishedD.resolve(SYMBOL_FINISHED);
-    return originalThrow(...args);
+    finishedD.resolve(err);
+    return originalThrow(err);
   };
@@ -96,0 +99,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

52089

increased by1.06%

Lines of code

439

increased by2.09%

No dependency changes