stream: async iterator stop read if destroyed

Fixes some compatibility issues where it is expected that for await stops reading when the stream is destroyed. Refs: nodejs#34887
nxtedition · Oct 14, 2020 · 2c9432b · 2c9432b
1 parent 999e7d7
commit 2c9432b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js
@@ -1095,7 +1095,7 @@ async function* createAsyncIterator(stream) {
 
   try {
     while (true) {
-      const chunk = stream.read();
+      const chunk = stream.destroyed ? null : stream.read();
       if (chunk !== null) {
         yield chunk;
       } else if (errorEmitted) {

diff --git a/test/parallel/test-stream-readable-async-iterators.js b/test/parallel/test-stream-readable-async-iterators.js
@@ -43,8 +43,6 @@ async function tests() {
     });
 
     const iter = Readable.prototype[Symbol.asyncIterator].call(stream);
-    await iter.next();
-    await iter.next();
     await iter.next()
       .then(common.mustNotCall())
       .catch(common.mustCall((err) => {