1 files changed, 53 insertions, 0 deletions
diff --git a/test/issue-2349.js b/test/issue-2349.js
new file mode 100644
index 0000000..a82bb74
--- /dev/null
+++ b/test/issue-2349.js
@@ -0,0 +1,53 @@
+'use strict'
+
+const { test, skip } = require('tap')
+const { nodeMajor } = require('../lib/core/util')
+const { Writable } = require('stream')
+const { MockAgent, errors, stream } = require('..')
+
+if (nodeMajor < 16) {
+  skip('only for node 16')
+  process.exit(0)
+}
+
+test('stream() does not fail after request has been aborted', async (t) => {
+  t.plan(1)
+
+  const mockAgent = new MockAgent()
+
+  mockAgent.disableNetConnect()
+  mockAgent
+    .get('http://localhost:3333')
+    .intercept({
+      path: '/'
+    })
+    .reply(200, 'ok')
+    .delay(10)
+
+  const parts = []
+  const ac = new AbortController()
+
+  setTimeout(() => ac.abort('nevermind'), 5)
+
+  try {
+    await stream(
+      'http://localhost:3333/',
+      {
+        opaque: { parts },
+        signal: ac.signal,
+        dispatcher: mockAgent
+      },
+      ({ opaque: { parts } }) => {
+        return new Writable({
+          write (chunk, _encoding, callback) {
+            parts.push(chunk)
+            callback()
+          }
+        })
+      }
+    )
+  } catch (error) {
+    console.log(error)
+    t.equal(error instanceof errors.RequestAbortedError, true)
+  }
+})