import { IServerSideEventStreamer } from 'flowise-components';
export declare class RedisEventPublisher implements IServerSideEventStreamer {
    private redisPublisher;
    private connectPromise;
    constructor();
    private setupEventListeners;
    isConnected(): boolean;
    connect(): Promise<void>;
    private safePublish;
    streamCustomEvent(chatId: string, eventType: string, data: any): void;
    streamStartEvent(chatId: string, data: string): void;
    streamTokenEvent(chatId: string, data: string): void;
    streamThinkingEvent(chatId: string, data: string, duration?: number): void;
    streamSourceDocumentsEvent(chatId: string, data: any): void;
    streamArtifactsEvent(chatId: string, data: any): void;
    streamUsedToolsEvent(chatId: string, data: any): void;
    streamCalledToolsEvent(chatId: string, data: any): void;
    streamFileAnnotationsEvent(chatId: string, data: any): void;
    streamToolEvent(chatId: string, data: any): void;
    streamAgentReasoningEvent(chatId: string, data: any): void;
    streamAgentFlowEvent(chatId: string, data: any): void;
    streamAgentFlowExecutedDataEvent(chatId: string, data: any): void;
    streamNextAgentEvent(chatId: string, data: any): void;
    streamNextAgentFlowEvent(chatId: string, data: any): void;
    streamActionEvent(chatId: string, data: any): void;
    streamAbortEvent(chatId: string): void;
    streamEndEvent(_: string): void;
    streamErrorEvent(chatId: string, msg: string): void;
    streamMetadataEvent(chatId: string, apiResponse: any): void;
    streamUsageMetadataEvent(chatId: string, data: any): void;
    streamTTSStartEvent(chatId: string, chatMessageId: string, format: string): void;
    streamTTSDataEvent(chatId: string, chatMessageId: string, audioChunk: string): void;
    streamTTSEndEvent(chatId: string, chatMessageId: string): void;
    streamTTSAbortEvent(chatId: string, chatMessageId: string): void;
    disconnect(): Promise<void>;
}