Function pushToStreamer

src/openai-handler.ts:827–862

(text: string)

        let hybridReasoningSent = false;

        const pushToStreamer = (text: string): void => {
            if (!text || toolMarkerDetected) return;
            pendingText += text;
            const idx = pendingText.indexOf(TOOL_MARKER);
            if (idx >= 0) {
                const before = pendingText.substring(0, idx);
                if (before) {
                    const d = hybridStreamer.push(before);
                    if (d) {
                        if (thinkingEnabled && hybridThinkingContent && !hybridReasoningSent) {
                            writeOpenAIReasoningDelta(res, id, created, model, hybridThinkingContent);
                            hybridReasoningSent = true;
                        }
                        writeOpenAITextDelta(res, id, created, model, d);
                        hybridTextSent = true;
                    }
                }
                toolMarkerDetected = true;
                pendingText = '';
                return;
            }
            const safeEnd = pendingText.length - MARKER_LOOKBACK;
            if (safeEnd > 0) {
                const safe = pendingText.substring(0, safeEnd);
                pendingText = pendingText.substring(safeEnd);
                const d = hybridStreamer.push(safe);
                if (d) {
                    if (thinkingEnabled && hybridThinkingContent && !hybridReasoningSent) {
                        writeOpenAIReasoningDelta(res, id, created, model, hybridThinkingContent);
                        hybridReasoningSent = true;
                    }
                    writeOpenAITextDelta(res, id, created, model, d);
                    hybridTextSent = true;
                }
            }
        };

        const processHybridDelta = (delta: string): void => {
            if (!hybridLeadingResolved) {