fixup

lib/client-base.js

@@ -709,9 +709,26 @@ function resume (client) {
       // Only allow one active request with reset.
 
       const pending = client[kQueue][client[kPendingIdx]]
-      const running = client[kQueue][client[kRunningIdx]]
+      if (pending.reset) {
+        const { streaming, body } = pending
+
+        if (streaming) {
+          if (typeof body.read === 'function') {
+            body.read(0)
+          }
+          const state = body._readableState
+          if (state && state.ended && state.length === 0) {
+            pending.reset = false
+          } else {
+            return
+          }
+        } else {
+          return
+        }
+      }
 
-      if (pending.reset || running.reset) {
+      const running = client[kQueue][client[kRunningIdx]]
+      if (running.reset) {
         return
       }
     }

lib/request.js

@@ -99,15 +99,6 @@ class Request extends AsyncResource {
     // to parse the body as a request and provide two responses, corrupting
     // undici state.
     this.reset = this.body && (method === 'HEAD' || method === 'GET')
-    if (this.reset && this.streaming) {
-      if (typeof body.read === 'function') {
-        body.read(0)
-      }
-      const state = body._readableState
-      if (state && state.ended && state.length === 0) {
-        this.reset = false
-      }
-    }
 
     {
       // TODO (perf): Build directy into buffer instead of