123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
import { ActorRef, EmittedFrom } from '.';
interface WaitForOptions {  /**   * How long to wait before rejecting, if no emitted   * state satisfies the predicate.   *   * @default 10_000 (10 seconds)   */  timeout: number;}
const defaultWaitForOptions: WaitForOptions = {  timeout: 10_000 // 10 seconds};
/** * Subscribes to an actor ref and waits for its emitted value to satisfy * a predicate, and then resolves with that value. * * @example * ```js * const state = await waitFor(someService, state => { *   return state.hasTag('loaded'); * }); * * state.hasTag('loaded'); // true * ``` * * @param actorRef The actor ref to subscribe to * @param predicate Determines if a value matches the condition to wait for * @param options * @returns A promise that eventually resolves to the emitted value * that matches the condition */export function waitFor<TActorRef extends ActorRef<any, any>>(  actorRef: TActorRef,  predicate: (emitted: EmittedFrom<TActorRef>) => boolean,  options?: Partial<WaitForOptions>): Promise<EmittedFrom<TActorRef>> {  const resolvedOptions: WaitForOptions = {    ...defaultWaitForOptions,    ...options  };  return new Promise((res, rej) => {    let done = false;    if (process.env.NODE_ENV !== 'production' && resolvedOptions.timeout < 0) {      console.error(        '`timeout` passed to `waitFor` is negative and it will reject its internal promise immediately.'      );    }    const handle =      resolvedOptions.timeout === Infinity        ? undefined        : setTimeout(() => {            sub.unsubscribe();            rej(new Error(`Timeout of ${resolvedOptions.timeout} ms exceeded`));          }, resolvedOptions.timeout);
    const dispose = () => {      clearTimeout(handle!);      done = true;      sub?.unsubscribe();    };
    const sub = actorRef.subscribe({      next: (emitted) => {        if (predicate(emitted)) {          dispose();          res(emitted);        }      },      error: (err) => {        dispose();        rej(err);      },      complete: () => {        dispose();        rej(new Error(`Actor terminated without satisfying predicate`));      }    });    if (done) {      sub.unsubscribe();    }  });}