import { WebSocket } from 'ws';
import { type WatchStream, type WatchStreamResult, type WatchStreamOptions } from '@quenty/nevermore-deploy';
export interface WebSocketWatchStreamOptions {
    /**
     * The register endpoint this monitor was created against. The stream URL is
     * derived from it so the host is configured in exactly one place, and so no
     * service address is ever written down in this repo.
     */
    registerUrl: string;
    /** Injected in tests. */
    connect?: (url: string, headers: Record<string, string>) => WebSocket;
    /** Injected in tests; a real session cannot wait ten seconds per assertion. */
    healthyConnectionMs?: number;
}
export declare class WebSocketWatchStream implements WatchStream {
    private readonly _registerUrl;
    private readonly _connect;
    private readonly _healthyConnectionMs;
    constructor(options: WebSocketWatchStreamOptions);
    runAsync(options: WatchStreamOptions): Promise<WatchStreamResult>;
    /** `.../v1/register/30m/` and `.../v1/monitors/{id}/stream` share a root. */
    private _streamUrl;
    private _holdAsync;
}
//# sourceMappingURL=websocket-watch-stream.d.ts.map