import "../_dnt.polyfills.js";
import { Deferred } from "../deps/std/async.js";
import { RpcCallMessage, RpcIngressMessage, RpcSubscriptionHandler } from "./rpc_messages.js";
export declare abstract class Connection {
    #private;
    nextId: number;
    references: number;
    signal: AbortSignal;
    static bind<D>(this: new (discovery: D) => Connection, discovery: D): Connect;
    static connect<D>(this: new (discovery: D) => Connection, discovery: D, signal: AbortSignal): Connection;
    ref(signal: AbortSignal): void;
    abstract ready(): Promise<void>;
    abstract send(id: number, method: string, params: unknown): void;
    protected abstract close(): void;
    call(method: string, params: unknown[]): Promise<RpcCallMessage>;
    callResultPendings: Record<number, Deferred<RpcCallMessage>>;
    subscriptionHandlers: Record<string, RpcSubscriptionHandler>;
    subscriptionPendingInits: Record<number, (subscriptionId: string) => void>;
    subscription(subscribe: string, unsubscribe: string, params: unknown[], handler: RpcSubscriptionHandler, signal: AbortSignal): Promise<void>;
    handle(message: RpcIngressMessage): void;
}
export type Connect = (signal: AbortSignal) => Connection;