import type { BaseClientOptions } from "../../../../BaseClient.js"; import { type NormalizedClientOptionsWithAuth } from "../../../../BaseClient.js"; import { StreamSocket } from "./Socket.js"; export declare namespace StreamClient { type Options = BaseClientOptions; interface ConnectArgs { id: string; tenantName: string; token: string; /** Additional query parameters to send with the websocket connect request. */ queryParams?: Record; /** Arbitrary headers to send with the websocket connect request. */ headers?: Record; /** Enable debug mode on the websocket. Defaults to false. */ debug?: boolean; /** Number of reconnect attempts. Defaults to 30. */ reconnectAttempts?: number; /** The timeout for establishing the WebSocket connection in seconds. */ connectionTimeoutInSeconds?: number; /** A signal to abort the WebSocket connection. */ abortSignal?: AbortSignal; } } export declare class StreamClient { protected readonly _options: NormalizedClientOptionsWithAuth; constructor(options: StreamClient.Options); connect(args: StreamClient.ConnectArgs): Promise; }