diff options
Diffstat (limited to 'std/http/racing_server.ts')
-rw-r--r-- | std/http/racing_server.ts | 50 |
1 files changed, 23 insertions, 27 deletions
diff --git a/std/http/racing_server.ts b/std/http/racing_server.ts index 9d118dc6d..17d982460 100644 --- a/std/http/racing_server.ts +++ b/std/http/racing_server.ts @@ -19,32 +19,28 @@ async function largeRespond(request: ServerRequest, c: string): Promise<void> { await request.respond({ status: 200, body: b }); } -async function main(): Promise<void> { - let step = 1; - for await (const request of server) { - switch (step) { - case 1: - // Try to wait long enough. - // For pipelining, this should cause all the following response - // to block. - delayedRespond(request); - break; - case 2: - // HUGE body. - largeRespond(request, "a"); - break; - case 3: - // HUGE body. - largeRespond(request, "b"); - break; - default: - request.respond({ status: 200, body: body4 }); - break; - } - step++; +console.log("Racing server listening...\n"); + +let step = 1; +for await (const request of server) { + switch (step) { + case 1: + // Try to wait long enough. + // For pipelining, this should cause all the following response + // to block. + delayedRespond(request); + break; + case 2: + // HUGE body. + largeRespond(request, "a"); + break; + case 3: + // HUGE body. + largeRespond(request, "b"); + break; + default: + request.respond({ status: 200, body: body4 }); + break; } + step++; } - -main(); - -console.log("Racing server listening...\n"); |