123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
import { Channel, Receiver, Sender } from "../channel.ts";import { AbortedError, UnreachableError } from "./errors.ts";
/** @internal */export const sleep = (duration: number) => {  return new Promise<void>((res) => {    setTimeout(() => res(), duration);  });};
/** @internal */export function recordWithDefaults<TKey extends string | symbol, TVal>(  record: Record<TKey, TVal>,  fn: (prop: TKey) => TVal,) {  return new Proxy(record, {    get: (target, prop: TKey) => {      if (target[prop] === undefined) {        target[prop] = fn(prop);      }      return target[prop];    },  });}
/** @internal */export function ignoreAbortedError(err: unknown): Promise<void> {  if (err instanceof AbortedError) return Promise.resolve();  return Promise.reject(err);}
/** @internal */export function makeAbortCtrl(  signal: AbortSignal | undefined,): AbortController | undefined {  if (!signal) return;  const ctrl = new AbortController();  signal.addEventListener("abort", () => ctrl.abort());  return ctrl;}
/** @internal */export function isSafeInteger(x: unknown): x is number {  return Number.isSafeInteger(x);}
/** @internal */export function isPositiveSafeInteger(x: unknown): x is number {  return isSafeInteger(x) && x > 0;}
/** @internal */export function isNonNegativeSafeInteger(x: unknown): x is number {  return isSafeInteger(x) && x >= 0;}
/** @internal */export function isSender(x: unknown): x is Sender<unknown> {  return x instanceof Channel;}
/** @internal */export function isReceiver(x: unknown): x is Receiver<unknown> {  return x instanceof Channel;}
/** @internal */export function raceAbort<T>(  p: Promise<T>,  type: "send" | "get",  signal?: AbortSignal,) {  if (!signal) return p;  return Promise.race([p, makeAbortPromise(type, signal)]);}
/** @internal */export function makeAbortPromise(  type: "send" | "get",  signal: AbortSignal,): Promise<never> {  const err = new AbortedError(type);  if (signal.aborted) return Promise.reject(err);  return new Promise((_, reject) => {    signal.addEventListener("abort", () => reject(err));  });}
/** @internal */export function deferPromise<T>(): [  Promise<T>,  (_: T | PromiseLike<T>) => void,  (_?: unknown) => void,] {  let res: undefined | ((_: T | PromiseLike<T>) => void);  let rej: undefined | ((_?: unknown) => void);  const p = new Promise<T>((res2, rej2) => {    res = res2;    rej = rej2;  });  if (!res) throw new UnreachableError();  if (!rej) throw new UnreachableError();  return [p, res, rej];}