Function waitForSDKEvent

packages/node-sdk/examples/runtime-smoke-helpers.ts:64–88

(
  session: Session,
  predicate: (event: Event) => boolean,
  timeoutMs = 30_000,
)

}

export function waitForSDKEvent(
  session: Session,
  predicate: (event: Event) => boolean,
  timeoutMs = 30_000,
): Promise<Event> {
  return new Promise((resolve, reject) => {
    const timeout = setTimeout(() => {
      unsubscribe();
      reject(new Error('Timed out waiting for session event'));
    }, timeoutMs);
    const unsubscribe = session.onEvent((event) => {
      logEvent(event);
      if (event.type === 'error') {
        clearTimeout(timeout);
        unsubscribe();
        reject(new Error(`${event.code}: ${event.message}`));
        return;
      }
      if (!predicate(event)) return;
      clearTimeout(timeout);
      unsubscribe();
      resolve(event);
    });
  });
}

interface PromptStreamWatcher {
  readonly started: Promise<number>;