fixup

Author: ronag

lib/internal/streams/duplexify.js

@@ -206,15 +206,17 @@ module.exports = function duplexify(body, name) {
 function fromAsyncGen(fn) {
   let { promise, resolve } = createDeferredPromise();
   const ac = new AbortController();
+  const signal = ac.signal;
   const value = fn(async function*() {
     while (true) {
       const { chunk, done, cb } = await promise;
       process.nextTick(cb);
       if (done) return;
+      if (signal.aborted) throw new AbortError();
       yield chunk;
       ({ promise, resolve } = createDeferredPromise());
     }
-  }(), { signal: ac.signal });
+  }(), { signal });
 
   return {
     value,