import { AblyBaseCommand } from "../../base-command.js";
export default class BenchSubscriber extends AblyBaseCommand {
    static args: {
        channelName: import("@oclif/core/interfaces").Arg<string, Record<string, unknown>>;
    };
    static description: string;
    static examples: string[];
    static flags: {
        duration: import("@oclif/core/interfaces").OptionFlag<number | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "client-id": import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        port: import("@oclif/core/interfaces").OptionFlag<number | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "tls-port": import("@oclif/core/interfaces").OptionFlag<number | undefined, import("@oclif/core/interfaces").CustomOptions>;
        tls: import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        verbose: import("@oclif/core/interfaces").BooleanFlag<boolean>;
        json: import("@oclif/core/interfaces").BooleanFlag<boolean>;
        "pretty-json": import("@oclif/core/interfaces").BooleanFlag<boolean>;
        "web-cli-help": import("@oclif/core/interfaces").BooleanFlag<boolean>;
    };
    private _flags;
    private receivedEchoCount;
    private checkPublisherIntervalId;
    private intervalId;
    private readonly MAX_LOG_LINES;
    private messageLogBuffer;
    private realtime;
    private testInProgress;
    private displayTable;
    finally(err: Error | undefined): Promise<void>;
    run(): Promise<void>;
    private addLogToBuffer;
    private checkInitialPresence;
    private createStatusDisplay;
    private finishTest;
    private handleChannel;
    private handlePresence;
    private resetDisplay;
    private setupClient;
    private startNewTest;
    private startPublisherCheckInterval;
    private subscribeToMessages;
    private updateStatusAndLogs;
    private waitForTermination;
}