import { AsyncStreamEmitter } from 'topgun-async-stream-emitter';
import { e as TGChannel, C as ChannelState } from './auth-291bd0a8.js';

declare class SimpleExchange extends AsyncStreamEmitter<any> {
    private readonly _broker;
    private readonly _channelMap;
    private readonly _channelEventDemux;
    private readonly _channelDataDemux;
    /**
     * Constructor
     */
    constructor(broker: SimpleBroker);
    destroy(): void;
    publish(channelName: string, data: any): Promise<void>;
    subscribe(channelName: string): TGChannel<any>;
    unsubscribe(channelName: string): void;
    channel(channelName: string): TGChannel<any>;
    getChannelState(channelName: string): ChannelState;
    getChannelOptions(channelName: string): {};
    subscriptions(includePending?: boolean): string[];
    isSubscribed(channelName: string, includePending?: boolean): boolean;
    private _triggerChannelSubscribe;
    private _triggerChannelUnsubscribe;
}

interface SimpleChannel {
    name: string;
    state: ChannelState;
}
interface SimpleSocket {
    id: string;
    transmit?(event: string, data: any, options?: any): Promise<void>;
}
interface SubscribeData {
    channel: string;
}
interface UnsubscribeData {
    channel: string;
}
interface ErrorData {
    error: any;
}
interface PublishData {
    channel: string;
    data: any;
}

declare class SimpleBroker extends AsyncStreamEmitter<any> {
    isReady: boolean;
    private readonly _exchangeClient;
    private readonly _clientSubscribers;
    private readonly _clientSubscribersCounter;
    /**
     * constructor
     */
    constructor();
    exchange(): SimpleExchange;
    subscribeSocket(socket: SimpleSocket, channelName: string): Promise<any>;
    unsubscribeSocket(socket: SimpleSocket, channelName: string): Promise<any>;
    subscriptions(): string[];
    isSubscribed(channelName: string): boolean;
    publish(channelName: string, data: any, suppressEvent?: boolean): Promise<void>;
}

export { ErrorData as E, PublishData as P, SimpleBroker as S, UnsubscribeData as U, SimpleExchange as a, SimpleChannel as b, SimpleSocket as c, SubscribeData as d };