fixup: tests

docs/api/Dispatcher.md

@@ -418,7 +418,7 @@ The `RequestOptions.method` property should not be value `'CONNECT'`.
 
 * **statusCode** `number`
 * **headers** `http.IncomingHttpHeaders`
-* **body** `stream.Readable`
+* **body** `stream.Readable` which also implements [the body mixin from the Fetch Standard](https://fetch.spec.whatwg.org/#body-mixin).
 * **trailers** `Record<string, string>` - This object starts out
   as empty and will be mutated to contain trailers after `body` has emitted `'end'`.
 * **opaque** `unknown`

lib/api/readable.js

@@ -49,6 +49,13 @@ module.exports = class BodyReadable extends Readable {
     return super.on(ev, ...args)
   }
 
+  addListener (ev, ...args) {
+    if (ev === 'data' || ev === 'readable') {
+      this[kReading] = true
+    }
+    return super.addListener(ev, ...args)
+  }
+
   push (chunk, encoding) {
     if (this[kConsume] && chunk !== null && !this[kReading]) {
       // Fast path.
@@ -90,6 +97,7 @@ module.exports = class BodyReadable extends Readable {
     return isDisturbed(this)
   }
 
+  // https://fetch.spec.whatwg.org/#dom-body-body
   get body () {
     if (this[kConsume] && this[kConsume].type === kWebStreamType) {
       return this[kConsume].stream
@@ -125,20 +133,16 @@ function isUnusable (self) {
 
 async function consume (parent, type) {
   if (isUnusable(parent)) {
-    // eslint-disable-next-line no-restricted-syntax
     throw new TypeError('unusable')
   }
 
   if (parent[kConsume]) {
-    // TODO: Should multiple consume in same tick be possible?
-    // eslint-disable-next-line no-restricted-syntax
     throw new TypeError('unusable')
   }
 
   if (type === kWebStreamType) {
     const consume = parent[kConsume] = {
       type,
-      // TODO: Optimized implementation for web streams.
       stream: Readable.toWeb(parent)
     }
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "undici",
-  "version": "4.3.0",
+  "version": "4.2.2",
   "description": "An HTTP/1.1 client, written from scratch for Node.js",
   "homepage": "https://undici.nodejs.org",
   "bugs": {