import type { Client as GqlWsClient } from 'graphql-ws';
/**
 * Collect the next event from a graphql-ws WebSocket subscription.
 *
 * Returns a promise that resolves with the first `next` payload's `data`,
 * or rejects on error / timeout. The subscription is automatically
 * unsubscribed after the first event.
 */
export declare function nextEvent<T = Record<string, unknown>>(client: GqlWsClient, query: string, variables?: Record<string, unknown>, timeoutMs?: number): Promise<T>;
/**
 * Subscribe and collect events into an array until `unsubscribe()` is called.
 *
 * Useful for assertions that need to inspect multiple events after the fact.
 */
export declare function collectWsEvents<T = Record<string, unknown>>(client: GqlWsClient, query: string, variables?: Record<string, unknown>): {
    events: T[];
    unsubscribe: () => void;
};
export declare const delay: (ms: number) => Promise<void>;