123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
import { TimeoutError, waitUntil, waitUntilAsync } from "./wait.ts";import { deferred, denoDelay } from "./deps.ts";import { assertEquals, assertThrowsAsync } from "./dev_deps.ts";
Deno.test("waitAsync return function return code", async () => {  const delay = 1000;  const result = Symbol("OK");  const fn = async () => result;  const actualResult = await waitUntilAsync(fn, delay);  assertEquals(actualResult, result);  await denoDelay(delay);});
Deno.test("waitAsync throw function exception", async () => {  const delay = 1000;  const errorMsg = "BOOM";  const fn = async () => {    throw new Error(errorMsg);  };  await assertThrowsAsync(    async () => await waitUntilAsync(fn, delay),    Error,    errorMsg,  );  await denoDelay(delay);});
Deno.test("waitAsync throw TimeoutError exception", async () => {  const delay = 1000;  const fn = async () => {    return deferred();  };  const error = await assertThrowsAsync(    async () => await waitUntilAsync(fn, delay),    TimeoutError,    "function did not complete within allowed time",  );  assertEquals((error as TimeoutError).isTimeout, true);  await denoDelay(delay);});
Deno.test("waitAsync throw custom Error exception", async () => {  const delay = 1000;  const fn = async () => {    return deferred();  };  const errorMsg = "BOOM";  const error = await assertThrowsAsync(    async () => await waitUntil(fn, delay, new Error(errorMsg)),    Error,    errorMsg,  );  assertEquals((error as any).isTimeout, undefined);  await denoDelay(delay);});
Deno.test("wait return function return code", async () => {  const delay = 1000;  const result = Symbol("OK");  const fn = () => result;  const actualResult = await waitUntil(fn, delay);  assertEquals(actualResult, result);  await denoDelay(delay);});
Deno.test("wait throw function exception", async () => {  const delay = 1000;  const errorMsg = "BOOM";  const fn = () => {    throw new Error(errorMsg);  };  await assertThrowsAsync(    async () => await waitUntil(fn, delay),    Error,    errorMsg,  );  await denoDelay(delay);});
Deno.test("wait throw TimeoutError exception", async () => {  const delay = 1000;  const fn = () => {    return deferred();  };  const error = await assertThrowsAsync(    async () => await waitUntil(fn, delay),    TimeoutError,    "function did not complete within allowed time",  );  assertEquals((error as TimeoutError).isTimeout, true);  await denoDelay(delay);});
Deno.test("wait throw custom Error exception", async () => {  const delay = 1000;  const fn = () => {    return deferred();  };  const errorMsg = "BOOM";  const error = await assertThrowsAsync(    async () => await waitUntil(fn, delay, new Error(errorMsg)),    Error,    errorMsg,  );  assertEquals((error as any).isTimeout, undefined);  await denoDelay(delay);});