import * as pg from "pg";
import type CursorType from "pg-cursor";
import type { SQLOptions, SocketSQLStreamServer } from "prostgles-types";
import type { VoidFunction } from "../SchemaWatch/SchemaWatch";
import type { DB } from "../initProstgles";
import type { DboBuilder } from "./DboBuilder";
import type { PRGLIOSocket } from "./DboBuilderTypes";
type ClientStreamedRequest = {
    socket: PRGLIOSocket;
    query: string;
    options: SQLOptions | undefined;
    persistConnection?: boolean;
};
type StreamedQuery = ClientStreamedRequest & {
    id: number;
    cursor: CursorType | undefined;
    client: pg.Client | undefined;
    stop?: VoidFunction;
    onError: (error: any) => void;
};
export declare class QueryStreamer {
    db: DB;
    dboBuilder: DboBuilder;
    socketQueries: Map<string, Map<number, StreamedQuery>>;
    adminClient: pg.Client;
    constructor(dboBuilder: DboBuilder);
    getConnection: (onError: ((err: any) => void) | undefined, extraOptions?: pg.ClientConfig) => pg.Client;
    onDisconnect: (socketId: string) => void;
    create: (query: ClientStreamedRequest) => SocketSQLStreamServer;
}
export {};
//# sourceMappingURL=QueryStreamer.d.ts.map