fixup

nodejs · Nov 19, 2021 · 854a752 · 854a752
1 parent 6fbe14d
commit 854a752
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/lib/internal/streams/destroy.js b/lib/internal/streams/destroy.js
@@ -326,12 +326,12 @@ function emitErrorCloseLegacy(stream, err) {
 }
 
 // Normalize destroy for legacy.
-function destroyer(stream, err) {
+function destroyer(stream, err, options) {
   if (!stream || isDestroyed(stream)) {
     return;
   }
 
-  if (!err && !isFinished(stream)) {
+  if (!err && !isFinished(stream) && options?.autoAbort !== false) {
     err = new AbortError();
   }
 

diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js
@@ -1150,7 +1150,9 @@ async function* createAsyncIterator(stream, options) {
       (error || options?.destroyOnReturn !== false) &&
       (error === undefined || stream._readableState.autoDestroy)
     ) {
-      destroyImpl.destroyer(stream, null);
+      destroyImpl.destroyer(stream, null, {
+        autoAbort: false
+      });
     }
   }
 }