import WebSocket from "ws";
import { ConnectionOptions } from "./schemas";
import { Table, TypeMap } from "apache-arrow";
type WebSocketApiSubset = Pick<WebSocket, "send" | "close" | "addEventListener" | "removeEventListener">;
type ConnectionTestHarness = {
    fetch: typeof fetch;
    WebSocket: {
        new (url: string, options?: WebSocket.ClientOptions): WebSocketApiSubset;
    };
    protocolVersion?: string | undefined;
};
type ExecuteOptions = {
    signal?: AbortSignal;
};
export declare class Connection {
    static connect(options: ConnectionOptions, testHarness?: ConnectionTestHarness): Promise<Connection>;
    static connectDirect(wsUrl: string, options: ConnectionOptions): Promise<Connection>;
    private options;
    private fetch;
    private fetchOptions;
    private WebSocket;
    private ws;
    private protocolVersion;
    private wsListeners;
    private sessionAbortController;
    constructor(options: ConnectionOptions, testHarness?: ConnectionTestHarness);
    private establishSession;
    private connectToWebSocket;
    private openWebSocket;
    execute<Schema extends TypeMap = TypeMap>(statement: string, options?: ExecuteOptions): Promise<Table<Schema>>;
    private waitForMessage;
    private addWsListener;
    private onWsError;
    private onWsClose;
    close(): void;
    [Symbol.dispose](): void;
}
export {};