123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.import { delay } from "./delay.ts";import {  assert,  assertInstanceOf,  assertRejects,  assertStrictEquals,} from "../assert/mod.ts";
// https://dom.spec.whatwg.org/#interface-AbortSignalfunction assertIsDefaultAbortReason(reason: unknown) {  assertInstanceOf(reason, DOMException);  assertStrictEquals(reason.name, "AbortError");}
Deno.test("delay()", async function () {  const start = new Date();  const delayedPromise = delay(100);  const result = await delayedPromise;  const diff = new Date().getTime() - start.getTime();  assert(result === undefined);  assert(diff >= 100);});
Deno.test("delay() handles abort", async function () {  const start = new Date();  const abort = new AbortController();  const { signal } = abort;  const delayedPromise = delay(100, { signal });  setTimeout(() => abort.abort(), 0);  const cause = await assertRejects(() => delayedPromise);  const diff = new Date().getTime() - start.getTime();  assert(diff < 100);  assertIsDefaultAbortReason(cause);});
Deno.test("delay() checks abort reason", async function (ctx) {  async function assertRejectsReason(reason: unknown) {    const start = new Date();    const abort = new AbortController();    const { signal } = abort;    const delayedPromise = delay(100, { signal });    setTimeout(() => abort.abort(reason), 0);    const cause = await assertRejects(() => delayedPromise);    const diff = new Date().getTime() - start.getTime();    assert(diff < 100);    assertStrictEquals(cause, reason);  }
  await ctx.step("not-undefined values", async () => {    await Promise.all([      null,      new Error("Timeout cancelled"),      new DOMException("Timeout cancelled", "AbortError"),      new DOMException("The signal has been aborted", "AbortError"),    ].map(assertRejectsReason));  });
  await ctx.step("undefined", async () => {    const start = new Date();    const abort = new AbortController();    const { signal } = abort;    const delayedPromise = delay(100, { signal });    setTimeout(() => abort.abort(), 0);    const cause = await assertRejects(() => delayedPromise);    const diff = new Date().getTime() - start.getTime();    assert(diff < 100);    assertIsDefaultAbortReason(cause);  });});
Deno.test("delay() handles non-aborted signal", async function () {  const start = new Date();  const abort = new AbortController();  const { signal } = abort;  const delayedPromise = delay(100, { signal });  const result = await delayedPromise;  const diff = new Date().getTime() - start.getTime();  assert(result === undefined);  assert(diff >= 100);});
Deno.test("delay() handles aborted signal after delay", async function () {  const start = new Date();  const abort = new AbortController();  const { signal } = abort;  const delayedPromise = delay(100, { signal });  const result = await delayedPromise;  abort.abort();  const diff = new Date().getTime() - start.getTime();  assert(result === undefined);  assert(diff >= 100);});
Deno.test("delay() handles already aborted signal", async function () {  const start = new Date();  const abort = new AbortController();  abort.abort();  const { signal } = abort;  const delayedPromise = delay(100, { signal });  const cause = await assertRejects(() => delayedPromise);  const diff = new Date().getTime() - start.getTime();  assert(diff < 100);  assertIsDefaultAbortReason(cause);});