summaryrefslogtreecommitdiff
path: root/std/http/server.ts
diff options
context:
space:
mode:
Diffstat (limited to 'std/http/server.ts')
-rw-r--r--std/http/server.ts7
1 files changed, 4 insertions, 3 deletions
diff --git a/std/http/server.ts b/std/http/server.ts
index d8a6d88db..00f401f62 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 reader = new BufReader(conn);
- const writer = new BufWriter(conn);
+ const bufr = new BufReader(conn);
+ const w = new BufWriter(conn);
let req: ServerRequest | Deno.EOF = Deno.EOF;
let err: Error | undefined;
while (!this.closing) {
try {
- req = await readRequest(conn, reader, writer);
+ req = await readRequest(conn, bufr);
} catch (e) {
err = e;
}
@@ -161,6 +161,7 @@ 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