fix: use explicit flag for when use has interacted with stream (#3361)

lib/api/readable.js

@@ -14,6 +14,7 @@ const kBody = Symbol('kBody')
 const kAbort = Symbol('kAbort')
 const kContentType = Symbol('kContentType')
 const kContentLength = Symbol('kContentLength')
+const kUsed = Symbol('kUsed')
 const kBytesRead = Symbol('kBytesRead')
 
 const noop = () => {}
@@ -38,6 +39,7 @@ class BodyReadable extends Readable {
     this[kConsume] = null
     this[kBytesRead] = 0
     this[kBody] = null
+    this[kUsed] = false
     this[kContentType] = contentType
     this[kContentLength] = Number.isFinite(contentLength) ? contentLength : null
 
@@ -48,7 +50,7 @@ class BodyReadable extends Readable {
     this[kReading] = false
   }
 
-  destroy (err) {
+  _destroy (err, callback) {
     if (!err && !this._readableState.endEmitted) {
       err = new RequestAbortedError()
     }
@@ -57,15 +59,11 @@ class BodyReadable extends Readable {
       this[kAbort]()
     }
 
-    return super.destroy(err)
-  }
-
-  _destroy (err, callback) {
     // Workaround for Node "bug". If the stream is destroyed in same
     // tick as it is created, then a user who is waiting for a
     // promise (i.e micro tick) for installing a 'error' listener will
     // never get a chance and will always encounter an unhandled exception.
-    if (!this[kReading]) {
+    if (!this[kUsed]) {
       setImmediate(() => {
         callback(err)
       })
@@ -77,6 +75,7 @@ class BodyReadable extends Readable {
   on (ev, ...args) {
     if (ev === 'data' || ev === 'readable') {
       this[kReading] = true
+      this[kUsed] = true
     }
     return super.on(ev, ...args)
   }