Skip to content

Commit 6eed40a

Browse files
committed
now reasoning deltas stream in
1 parent 2ce0662 commit 6eed40a

1 file changed

Lines changed: 17 additions & 10 deletions

File tree

src/lib/streaming.ts

Lines changed: 17 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ export function streamText(
2121
}
2222

2323
let buffer = ''
24-
let reasoningSummaryBuffer = ''
2524

2625
const flush = () => {
2726
if (buffer) {
@@ -208,29 +207,37 @@ export function streamText(
208207

209208
case 'response.reasoning_summary_text.delta':
210209
if (typeof chunk.delta === 'string') {
211-
reasoningSummaryBuffer += chunk.delta
212-
}
213-
break
214-
215-
case 'response.reasoning_summary_text.done':
216-
if (reasoningSummaryBuffer) {
217210
controller.enqueue(
218211
encoder.encode(
219212
`t:${JSON.stringify({
220-
type: 'reasoning',
213+
type: 'reasoning_summary_delta',
214+
delta: chunk.delta,
221215
effort: chunk.effort,
222-
summary: reasoningSummaryBuffer,
223216
model: chunk.model,
224217
serviceTier: chunk.service_tier,
225218
temperature: chunk.temperature,
226219
topP: chunk.top_p,
227220
})}\n`,
228221
),
229222
)
230-
reasoningSummaryBuffer = ''
231223
}
232224
break
233225

226+
case 'response.reasoning_summary_text.done':
227+
controller.enqueue(
228+
encoder.encode(
229+
`t:${JSON.stringify({
230+
type: 'reasoning_summary_done',
231+
effort: chunk.effort,
232+
model: chunk.model,
233+
serviceTier: chunk.service_tier,
234+
temperature: chunk.temperature,
235+
topP: chunk.top_p,
236+
})}\n`,
237+
),
238+
)
239+
break
240+
234241
default:
235242
break
236243
}

0 commit comments

Comments
 (0)