fixuP

ronag · ronag · commit f1c5c103bf56 · 2021-07-07T15:01:22.000+02:00
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);
       }
