test: async iterate destroyed stream

PR-URL: #28995 Reviewed-By: Anna Henningsen <[email protected]> Reviewed-By: James M Snell <[email protected]> Reviewed-By: Trivikram Kamat <[email protected]>
nodejs · Feb 14, 2020 · df1592d · df1592d
1 parent 0c7ff7f
commit df1592d
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/test/parallel/test-stream-readable-async-iterators.js b/test/parallel/test-stream-readable-async-iterators.js
@@ -353,6 +353,22 @@ async function tests() {
  assert.strictEqual(received, 1);
  }
 
+ {
+ console.log('destroyed will not deadlock');
+ const readable = new Readable();
+ readable.destroy();
+ process.nextTick(async () => {
+ readable.on('close', common.mustNotCall());
+ let received = 0;
+ for await (const k of readable) {
+ // Just make linting pass. This should never run.
+ assert.strictEqual(k, 'hello');
+ received++;
+ }
+ assert.strictEqual(received, 0);
+ });
+ }
+
  {
  console.log('push async');
  const max = 42;