import { assertEquals, assertRejects } from "../assert/mod.ts";import { delay } from "./delay.ts";import { deadline, DeadlineError } from "./deadline.ts";
Deno.test("deadline() returns fulfilled promise", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(100, { signal }) .catch(() => {}) .then(() => "Hello"); const result = await deadline(p, 1000); assertEquals(result, "Hello"); controller.abort();});
Deno.test("deadline() throws DeadlineError", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(1000, { signal }) .catch(() => {}) .then(() => "Hello"); await assertRejects(async () => { await deadline(p, 100); }, DeadlineError); controller.abort();});
Deno.test("deadline() throws when promise is rejected", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(100, { signal }) .catch(() => {}) .then(() => Promise.reject(new Error("booom"))); await assertRejects( async () => { await deadline(p, 1000); }, Error, "booom", ); controller.abort();});
Deno.test("deadline() handles non-aborted signal", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(100, { signal }) .catch(() => {}) .then(() => "Hello"); const abort = new AbortController(); const result = await deadline(p, 1000, { signal: abort.signal }); assertEquals(result, "Hello"); controller.abort();});
Deno.test("deadline() handles aborted signal after delay", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(100, { signal }) .catch(() => {}) .then(() => "Hello"); const abort = new AbortController(); const promise = deadline(p, 100, { signal: abort.signal }); abort.abort(); await assertRejects(async () => { await promise; }, DeadlineError); controller.abort();});
Deno.test("deadline() handles already aborted signal", async () => { const controller = new AbortController(); const { signal } = controller; const p = delay(100, { signal }) .catch(() => {}) .then(() => "Hello"); const abort = new AbortController(); abort.abort(); await assertRejects(async () => { await deadline(p, 100, { signal: abort.signal }); }, DeadlineError); controller.abort();});