import EventBusManager from '../EventBusManager';
/**
 * RxJS-enhanced wrapper for EventBusManager.
 * Supports stream access and pipe() only if rxjs is available.
 */
export declare class RxJSEventBusManager<EventMap extends Record<string, any>> {
    private base;
    constructor(base: EventBusManager<EventMap>);
    /** Emits an event through the base manager. */
    emit(event: keyof EventMap, payload: EventMap[keyof EventMap]): void;
    /** Subscribes to an event using the base manager. */
    on(event: keyof EventMap, handler: (payload: EventMap[keyof EventMap]) => void): {
        unsubscribe: () => void;
    } | undefined;
    /** Clears subscriptions through the base manager. */
    clear(): void;
    /**
     * Returns the RxJS stream if the delegate is RxJS-based.
     * If rxjs is not loaded yet, loads it on demand.
     */
    getStream(): Promise<any | null>;
    /**
     * Calls RxJS pipe() on the stream with dynamic operator loading.
     * If rxjs is not installed or not loaded, returns null.
     */
    pipe(...ops: any[]): Promise<any>;
    /** Returns the stored last event envelope. */
    getValue(): {
        type: string | undefined;
        payload: unknown;
    };
}
export default RxJSEventBusManager;