diff options
author | 2023-01-31 17:55:16 -0800 | |
---|---|---|
committer | 2023-01-31 17:55:16 -0800 | |
commit | cc4326cd829decc95d1f1f23998f97705637e04b (patch) | |
tree | 9ccaa829b6d48af521d5e5fcdbabc0dac8d186af /src/bun.js/http.exports.js | |
parent | c57b37d29f9d04780c7f7917789cf8b424710d23 (diff) | |
download | bun-cc4326cd829decc95d1f1f23998f97705637e04b.tar.gz bun-cc4326cd829decc95d1f1f23998f97705637e04b.tar.zst bun-cc4326cd829decc95d1f1f23998f97705637e04b.zip |
Re-run prettier after changes
Diffstat (limited to 'src/bun.js/http.exports.js')
-rw-r--r-- | src/bun.js/http.exports.js | 33 |
1 files changed, 13 insertions, 20 deletions
diff --git a/src/bun.js/http.exports.js b/src/bun.js/http.exports.js index dd3745b30..d7f6e7053 100644 --- a/src/bun.js/http.exports.js +++ b/src/bun.js/http.exports.js @@ -65,7 +65,7 @@ export class Server extends EventEmitter { var pendingResponse; var pendingError; var rejectFunction, resolveFunction; - var reject = (err) => { + var reject = err => { if (pendingError) return; pendingError = err; if (rejectFunction) rejectFunction(err); @@ -80,8 +80,8 @@ export class Server extends EventEmitter { const http_req = new RequestClass(req); const http_res = new ResponseClass({ reply, req: http_req }); - http_req.once("error", (err) => reject(err)); - http_res.once("error", (err) => reject(err)); + http_req.once("error", err => reject(err)); + http_res.once("error", err => reject(err)); server.emit("request", http_req, http_res); if (pendingError) { @@ -99,11 +99,7 @@ export class Server extends EventEmitter { }, }); - if (onListen) - setTimeout( - () => onListen(null, this.#server.hostname, this.#server.port), - 0, - ); + if (onListen) setTimeout(() => onListen(null, this.#server.hostname, this.#server.port), 0); } catch (err) { if (onListen) { setTimeout(onListen, 0, err); @@ -201,15 +197,13 @@ export class IncomingMessage extends Readable { const contentLength = this.#req.headers.get("content-length"); let remaining = contentLength ? parseInt(contentLength, 10) : 0; this.#bodyStream = Readable.fromWeb(this.#req.body, { - highWaterMark: Number.isFinite(remaining) - ? Math.min(remaining, 16384) - : 16384, + highWaterMark: Number.isFinite(remaining) ? Math.min(remaining, 16384) : 16384, }); const isBodySizeKnown = remaining > 0 && Number.isSafeInteger(remaining); if (isBodySizeKnown) { - this.#bodyStream.on("data", (chunk) => { + this.#bodyStream.on("data", chunk => { this.push(chunk); // when we are streaming a known body size, automatically close the stream when we have read enough remaining -= chunk?.byteLength ?? 0; @@ -218,7 +212,7 @@ export class IncomingMessage extends Readable { } }); } else { - this.#bodyStream.on("data", (chunk) => { + this.#bodyStream.on("data", chunk => { this.push(chunk); }); } @@ -333,7 +327,7 @@ export class ServerResponse extends Writable { return; } - this.#ensureReadableStreamController((controller) => { + this.#ensureReadableStreamController(controller => { controller.write(chunk); callback(); }); @@ -346,7 +340,7 @@ export class ServerResponse extends Writable { return; } - this.#ensureReadableStreamController((controller) => { + this.#ensureReadableStreamController(controller => { for (const chunk of chunks) { controller.write(chunk.chunk); } @@ -365,13 +359,13 @@ export class ServerResponse extends Writable { new Response( new ReadableStream({ type: "direct", - pull: (controller) => { + pull: controller => { this.#controller = controller; if (firstWrite) controller.write(firstWrite); firstWrite = undefined; run(controller); if (!this.#finished) { - return new Promise((resolve) => { + return new Promise(resolve => { this.#deferred = resolve; }); } @@ -403,7 +397,7 @@ export class ServerResponse extends Writable { } this.#finished = true; - this.#ensureReadableStreamController((controller) => { + this.#ensureReadableStreamController(controller => { controller.end(); callback(); @@ -685,8 +679,7 @@ function _writeHead(statusCode, reason, obj, response) { response.statusMessage = reason; } else { // writeHead(statusCode[, headers]) - if (!response.statusMessage) - response.statusMessage = STATUS_CODES[statusCode] || "unknown"; + if (!response.statusMessage) response.statusMessage = STATUS_CODES[statusCode] || "unknown"; obj = reason; } response.statusCode = statusCode; |