feat: add abort signal to body.dump()

lib/api/readable.js

@@ -146,15 +146,23 @@ module.exports = class BodyReadable extends Readable {
 
   async dump (opts) {
     let limit = opts && Number.isFinite(opts.limit) ? opts.limit : 262144
+    const signal = opts && opts.signal && opts.signal instanceof AbortSignal ? opts.signal : null
+    if (signal) {
+      signal.addEventListener('abort', () => {
+        this.destroy()
+      })
+    }
     try {
       for await (const chunk of this) {
         limit -= Buffer.byteLength(chunk)
         if (limit < 0) {
           return
         }
       }
-    } catch {
-      // Do nothing...
+    } catch (err) {
+      if (err.name === 'AbortError') {
+        throw err
+      }
     }
   }
 }

test/client-request.js

@@ -1,3 +1,5 @@
+/* globals AbortController */
+
 'use strict'
 
 const { test } = require('tap')
@@ -41,6 +43,32 @@ test('request dump', (t) => {
   })
 })
 
+test('request dump with abort signal', (t) => {
+  t.plan(2)
+  const server = createServer((req, res) => {
+    res.write('hello')
+  })
+  t.teardown(server.close.bind(server))
+
+  server.listen(0, () => {
+    const client = new Client(`http://localhost:${server.address().port}`)
+    t.teardown(client.destroy.bind(client))
+
+    client.request({
+      path: '/',
+      method: 'GET'
+    }, (err, { body }) => {
+      t.error(err)
+      const ac = new AbortController()
+      body.dump({ signal: ac.signal }).catch((err) => {
+        t.equal(err.name, 'AbortError')
+        server.close()
+      })
+      ac.abort()
+    })
+  })
+})
+
 test('request abort before headers', (t) => {
   t.plan(6)