diff options
Diffstat (limited to 'std/http/server.ts')
-rw-r--r-- | std/http/server.ts | 7 |
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 |