import { TwinTransport, PeerInfo, SignalingSink } from './types';
export interface FanoutSession<H> {
    connect(): Promise<H>;
    ingestSignalingMessage(message: any): Promise<void> | void;
    close(): void;
}
export interface ResponderFanoutOptions<H> {
    transport: TwinTransport;
    targetTwinId: string;
    channelPrefix: string;
    maxPeers?: number;
    connectTimeoutMs?: number;
    createSession: (peerId: string, replyToTwinId: string, onClosed: () => void, signalingSink?: SignalingSink) => FanoutSession<H>;
    onPeer: (handle: H, peerId: string, info: PeerInfo) => void;
    onPeerClosed?: (peerId: string, error?: Error) => void;
}
export declare class ResponderFanout<H> {
    private opts;
    private peers;
    private preOfferBuffer;
    private connectTimers;
    private messageHandler;
    private started;
    private closed;
    constructor(opts: ResponderFanoutOptions<H>);
    start(): Promise<void>;
    getPeerCount(): number;
    ingestExternalOffer(peerId: string, offerSdp: string): Promise<string>;
    removePeer(peerId: string, error?: Error): void;
    close(): void;
    private clearConnectTimer;
    private onMessage;
    private spawnPeer;
}
//# sourceMappingURL=responder-fanout.d.ts.map