diff options
author | Divy Srivastava <dj.srivastava23@gmail.com> | 2024-11-07 17:12:13 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-11-07 17:12:13 +0530 |
commit | b9262130fec34137e38c922015c6b671c0fa9396 (patch) | |
tree | f8095a4939560aadbf9bd11d2dcc55f75d4e38a4 /tests | |
parent | 742744d4985548a948bc90e78673c0c22d607d8a (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.ts | 29 |
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); +}); |