Function waitFor

packages/node/src/__tests__/worker_integration.test.ts:77–108

(worker: Worker, pred: (m: Msg) => boolean)

}

function waitFor(worker: Worker, pred: (m: Msg) => boolean): Promise<Msg> {
  return new Promise((resolve, reject) => {
    const onMsg = (m: unknown) => {
      if (typeof m !== "object" || m === null) return;
      const type = (m as { type?: unknown }).type;
      if (typeof type !== "string") return;
      const msg = m as Msg;
      if (msg.type === "fatal") {
        cleanup();
        reject(new Error(`worker fatal: ${msg.where} (${msg.code}): ${msg.detail}`));
        return;
      }
      if (pred(msg)) {
        cleanup();
        resolve(msg);
      }
    };

    const onExit = (code: number) => {
      cleanup();
      reject(new Error(`worker exited before expected message: code=${String(code)}`));
    };

    const cleanup = () => {
      worker.off("message", onMsg);
      worker.off("exit", onExit);
    };

    worker.on("message", onMsg);
    worker.on("exit", onExit);
  });
}

function post(worker: Worker, msg: MainToWorkerMessage, transfer?: readonly ArrayBuffer[]): void {
  if (transfer !== undefined) {