development/deno
development/deno
1
0
Fork 0
mirror of https://github.com/denoland/deno synced 2024-11-05 18:45:24 +00:00
Code Issues Projects Releases Packages Wiki Activity

chore(ext/http): deno fmt (#12798)

Browse source
This commit is contained in:
Bert Belder 2021-11-12 11:21:58 -08:00
parent c4c8543d5c
commit 6a797f7ba9
No known key found for this signature in database
GPG key ID: 7A77887B2E2ED461
1 changed files with 10 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
ext/http/01_http.js
View file

@ -64,10 +64,7 @@
async nextRequest() {
let nextRequest;
try {
nextRequest = await core.opAsync(
"op_http_accept",
this.#rid,
);
nextRequest = await core.opAsync("op_http_accept", this.#rid);
} catch (error) {
this.close();
// A connection error seen here would cause disrupted responses to throw
@ -93,12 +90,7 @@
return null;
}
const [
streamRid,
method,
headersList,
url,
] = nextRequest;
const [streamRid, method, headersList, url] = nextRequest;
SetPrototypeAdd(this.managedResources, streamRid);
/** @type {ReadableStream<Uint8Array> | undefined} */
@ -202,15 +194,16 @@
} else {
respBody = new Uint8Array(0);
}
const isStreamingResponseBody =
!(typeof respBody === "string" || respBody instanceof Uint8Array);
const isStreamingResponseBody = !(
typeof respBody === "string" || respBody instanceof Uint8Array
);
try {
await core.opAsync("op_http_write_headers", [
streamRid,
innerResp.status ?? 200,
innerResp.headerList,
], isStreamingResponseBody ? null : respBody);
await core.opAsync(
"op_http_write_headers",
[streamRid, innerResp.status ?? 200, innerResp.headerList],
isStreamingResponseBody ? null : respBody,
);
} catch (error) {
const connError = httpConn[connErrorSymbol];
if (error instanceof BadResource && connError != null) {