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;