import { Subject } from 'rxjs';
import { ConnectorCommand, ConnectorState } from '../../Enum.js';
import type { IConnectorOptions, IListenerInfo, IRawNetPacket } from '../../interface/rpc.js';
import { type ExError } from '../../utility/ExError.js';
import { LifeCycle } from '../../utility/LifeCycle.js';
import type { Scope } from '../context/Scope.js';
import { Codec } from './Codec.js';
import type { Notify } from './packet/Notify.js';
declare abstract class Connector {
    constructor(options: IConnectorOptions);
    abstract isAvailable(): boolean;
    abstract get protocol(): string;
    waitForReady(ttlMs: number): Promise<void>;
    protected abstract connect(target: IListenerInfo): Promise<void>;
    start(target: IListenerInfo, codec: Codec<any>): Promise<void>;
    abstract selectCodec(code: string): Promise<void>;
    onCodecSelected(code: string): Promise<void>;
    protected abstract disconnect(): Promise<void>;
    off(): Promise<void>;
    private onError;
    abstract send<RequestPayload>(request: IRawNetPacket<RequestPayload>): Promise<void>;
    abstract sendRaw(request: object): Promise<void>;
    sendNotify(notify: Notify, fromId?: string | null): Promise<void>;
    sendCommand(command: ConnectorCommand, args?: unknown): Promise<void>;
    protected sendPing(id: number): Promise<void>;
    protected sendPong(id: number): Promise<void>;
    protected enablePingPong(): void;
    protected onPingError(err: ExError): void;
    protected disablePingPong(): void;
    protected handleIncomeMessage(data: IRawNetPacket): Promise<void>;
    protected handleCommand(command: ConnectorCommand, args: unknown): Promise<void>;
    get state(): ConnectorState;
    get stateSubject(): import("rxjs").BehaviorSubject<ConnectorState>;
    get session(): string | undefined;
    set session(value: string | undefined);
    get target(): IListenerInfo | undefined;
    get dataSubject(): Subject<IRawNetPacket>;
    get scope(): Scope<unknown>;
    protected lifeCycle_: LifeCycle<ConnectorState>;
    protected target_?: IListenerInfo;
    protected codec_?: Codec<any>;
    protected session_: string | undefined;
    private scope_;
    private pongWaiter_;
    private pingSub_;
    private options_;
    private subManager_;
    private dataSubject_;
}
export { Connector };
//# sourceMappingURL=Connector.d.ts.map