import * as russh from './native';
import { AsyncSubject, Observable, Subject } from "rxjs";
declare class ChannelEventBuffer<T = void> {
    #private;
    private getBuffer;
    next(channel: number, item: T): void;
    subscribe(channel: number): Observable<T>;
    closeChannel(channel: number): void;
    complete(): void;
}
export declare class ClientEventInterface {
    data$: ChannelEventBuffer<Uint8Array>;
    extendedData$: ChannelEventBuffer<[number, Uint8Array]>;
    eof$: ChannelEventBuffer<void>;
    close$: ChannelEventBuffer<void>;
    disconnect$: Subject<void>;
    x11ChannelOpen$: Subject<[russh.NewSshChannel, string, number]>;
    tcpChannelOpen$: Subject<[russh.NewSshChannel, string, number, string, number]>;
    agentChannelOpen$: Subject<[russh.NewSshChannel]>;
    banner$: AsyncSubject<string>;
    complete(): void;
    dataCallback: (_: unknown, channel: number, data: Uint8Array) => void;
    extendedDataCallback: (_: unknown, channel: number, ext: number, data: Uint8Array) => void;
    eofCallback: (_: unknown, channel: number) => void;
    closeCallback: (_: unknown, channel: number) => void;
    disconnectCallback: () => void;
    x11ChannelOpenCallback: (_: unknown, channel: russh.NewSshChannel, address: string, port: number) => void;
    tcpChannelOpenCallback: (_: unknown, channel: russh.NewSshChannel, connectedAddress: string, connectedPort: number, originatorAddress: string, originatorPort: number) => void;
    agentChannelOpenCallback: (_: unknown, channel: russh.NewSshChannel) => void;
    bannerCallback: (_: unknown, banner: string) => void;
}
export {};