@@ -324,2 +324,5 @@ import { FastURL, lazyInherit } from "../_chunks/_url.mjs"; | ||
| } | ||
| function isBodySourceFinished(req) { | ||
| return isClientGone(req) || req.destroyed || req.readableEnded; | ||
| } | ||
| const NodeRequest = /* @__PURE__ */ (() => { | ||
@@ -428,4 +431,4 @@ const NativeRequest = getNativeRequest(); | ||
| if (this.#hasBody() && !this.#bodyUsed) { | ||
| stream = Readable.toWeb(this.#req); | ||
| if (Readable.isDisturbed(stream)) stream = erroredStream(this.#bodyError()); | ||
| if (isBodySourceFinished(this.#req)) stream = erroredStream(this.#bodyError()); | ||
| else stream = Readable.toWeb(this.#req); | ||
| } | ||
@@ -451,3 +454,3 @@ if (stream && this.#maxRequestBodySize !== void 0) stream = limitBodyStream(stream, this.#maxRequestBodySize); | ||
| #readBuffered() { | ||
| if (isClientGone(this.#req) || this.#req.destroyed || this.#req.readableEnded) return Promise.reject(this.#bodyError()); | ||
| if (isBodySourceFinished(this.#req)) return Promise.reject(this.#bodyError()); | ||
| return readBody(this.#req, this.#maxRequestBodySize); | ||
@@ -454,0 +457,0 @@ } |
+1
-1
@@ -222,3 +222,3 @@ import { bold, cyan, gray, green, magenta, red, url, yellow } from "./_chunks/_utils.mjs"; | ||
| name: "srvx", | ||
| version: "0.12.5", | ||
| version: "0.12.6", | ||
| description: "Universal Server." | ||
@@ -225,0 +225,0 @@ }; |
+1
-1
| { | ||
| "name": "srvx", | ||
| "version": "0.12.6", | ||
| "version": "0.12.7", | ||
| "description": "Universal Server.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://srvx.h3.dev", |
URL strings
Supply chain riskPackage contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.
URL strings
Supply chain riskPackage contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.
180246
0.04%3657
0.08%