nodejs
diff --git a/Collapse file
‎lib/internal/streams/async_iterator.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/async_iterator.js
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎lib/internal/streams/async_iterator.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/async_iterator.js
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-stream-readable-async-iterators.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-readable-async-iterators.js
+12Lines changed: 12 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-readable-async-iterators.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-readable-async-iterators.js
+12Lines changed: 12 additions & 0 deletions
@@ -58,7 +58,7 @@ function onError(iter, err) {
     iter[kLastReject] = null;
     reject(err);
   }
-  iter.error = err;
+  iter[kError] = err;
 }
 
 function wrapForNext(lastPromise, iter) {
 
@@ -115,6 +115,18 @@ async function tests() {
     readable.destroy(new Error('kaboom'));
   })();
 
+  await (async function() {
+    console.log('call next() after error');
+    const readable = new Readable({
+      read() {}
+    });
+    const iterator = readable[Symbol.asyncIterator]();
+
+    const err = new Error('kaboom');
+    readable.destroy(new Error('kaboom'));
+    await assert.rejects(iterator.next.bind(iterator), err);
+  })();
+
   await (async function() {
     console.log('read object mode');
     const max = 42;
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ function onError(iter, err) {`
`58`	`58`	`iter[kLastReject] = null;`
`59`	`59`	`reject(err);`
`60`	`60`	`}`
`61`		`- iter.error = err;`
	`61`	`+ iter[kError] = err;`
`62`	`62`	`}`
`63`	`63`
`64`	`64`	`function wrapForNext(lastPromise, iter) {`