summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorDivy Srivastava <dj.srivastava23@gmail.com>2024-11-07 17:12:13 +0530
committerGitHub <noreply@github.com>2024-11-07 17:12:13 +0530
commitb9262130fec34137e38c922015c6b671c0fa9396 (patch)
treef8095a4939560aadbf9bd11d2dcc55f75d4e38a4 /tests
parent742744d4985548a948bc90e78673c0c22d607d8a (diff)
feat(ext/http): abort signal when request is cancelled (#26761)
Closes https://github.com/denoland/deno/issues/21653
Diffstat (limited to 'tests')
-rw-r--r--tests/unit/serve_test.ts29
1 files changed, 29 insertions, 0 deletions
diff --git a/tests/unit/serve_test.ts b/tests/unit/serve_test.ts
index 439d71d55..9822a0ce2 100644
--- a/tests/unit/serve_test.ts
+++ b/tests/unit/serve_test.ts
@@ -4270,3 +4270,32 @@ Deno.test({
assertEquals(hostname, "0.0.0.0");
await server.shutdown();
});
+
+Deno.test({
+ name: "AbortSignal aborted when request is cancelled",
+}, async () => {
+ const { promise, resolve } = Promise.withResolvers<void>();
+
+ let cancelled = false;
+
+ const server = Deno.serve({
+ hostname: "0.0.0.0",
+ port: servePort,
+ onListen: () => resolve(),
+ }, async (request) => {
+ request.signal.addEventListener("abort", () => cancelled = true);
+ assert(!request.signal.aborted);
+ await new Promise((resolve) => setTimeout(resolve, 3000)); // abort during waiting
+ assert(request.signal.aborted);
+ return new Response("Ok");
+ });
+
+ await promise;
+ await fetch(`http://localhost:${servePort}/`, {
+ signal: AbortSignal.timeout(1000),
+ }).catch(() => {});
+
+ await server.shutdown();
+
+ assert(cancelled);
+});