Method streamThinkingEvent

packages/server/src/utils/SSEStreamer.ts:173–180

(chatId: string, data: string, duration?: number)

    }

    streamThinkingEvent(chatId: string, data: string, duration?: number) {
        const clientResponse = {
            event: 'thinking',
            data: data,
            duration: duration
        }
        this.safeWrite(chatId, 'message:\ndata:' + JSON.stringify(clientResponse) + '\n\n')
    }

    streamSourceDocumentsEvent(chatId: string, data: any) {
        const clientResponse = {