summaryrefslogtreecommitdiff
path: root/std/http/server.ts
diff options
context:
space:
mode:
authorNayeem Rahman <nayeemrmn99@gmail.com>2020-04-01 09:24:05 +0100
committerGitHub <noreply@github.com>2020-04-01 10:24:05 +0200
commit017a611131a35ccf5dbfce6a2a665fa569e32ec1 (patch)
tree49f07dfc25f8fdf45dae2f812941f42e9274bea6 /std/http/server.ts
parent857d96001d63c1cb847f3f228124d69c40d267e7 (diff)
feat(std/http/server): Respond with 400 on request parse failure (#4551)
Diffstat (limited to 'std/http/server.ts')
-rw-r--r--std/http/server.ts7
1 files changed, 3 insertions, 4 deletions
diff --git a/std/http/server.ts b/std/http/server.ts
index 00f401f62..d8a6d88db 100644
--- a/std/http/server.ts
+++ b/std/http/server.ts
@@ -146,14 +146,14 @@ export class Server implements AsyncIterable<ServerRequest> {
private async *iterateHttpRequests(
conn: Conn
): AsyncIterableIterator<ServerRequest> {
- const bufr = new BufReader(conn);
- const w = new BufWriter(conn);
+ const reader = new BufReader(conn);
+ const writer = new BufWriter(conn);
let req: ServerRequest | Deno.EOF = Deno.EOF;
let err: Error | undefined;
while (!this.closing) {
try {
- req = await readRequest(conn, bufr);
+ req = await readRequest(conn, reader, writer);
} catch (e) {
err = e;
}
@@ -161,7 +161,6 @@ export class Server implements AsyncIterable<ServerRequest> {
break;
}
- req.w = w;
yield req;
// Wait for the request to be processed before we accept a new request on