summaryrefslogtreecommitdiff
path: root/std/http/racing_server.ts
diff options
context:
space:
mode:
Diffstat (limited to 'std/http/racing_server.ts')
-rw-r--r--std/http/racing_server.ts50
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");