fix stream parser bug by adding flush()

jahooma · jahooma · commit 32197cb75b5e · 2025-11-25T19:35:53.000-08:00
diff --git a/packages/agent-runtime/src/tool-stream-parser.ts b/packages/agent-runtime/src/tool-stream-parser.ts
@@ -87,6 +87,7 @@ export async function* processStreamWithTools(params: {
     chunk: StreamChunk | undefined,
   ): Generator<StreamChunk> {
     if (chunk === undefined) {
+      flush()
       streamCompleted = true
       return
     }

Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,7 @@ export async function* processStreamWithTools(params: {`
`87`	`87`	`chunk: StreamChunk \| undefined,`
`88`	`88`	`): Generator<StreamChunk> {`
`89`	`89`	`if (chunk === undefined) {`
	`90`	`+ flush()`
`90`	`91`	`streamCompleted = true`
`91`	`92`	`return`
`92`	`93`	`}`