fixuP

nodejs · Jul 7, 2021 · f1c5c10 · f1c5c10
1 parent 37f31ad
commit f1c5c10
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js
@@ -1113,8 +1113,10 @@ async function* createAsyncIterator(stream, options) {
       const chunk = stream.destroyed ? null : stream.read();
       if (chunk !== null) {
         yield chunk;
-      } else if (error !== undefined) {
-        break;
+      } else if (error) {
+        throw error;
+      } else if (error === null) {
+        return;
       } else {
         await new Promise(next);
       }