apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-04-27 01:16:23 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

send reasoning blocks back to llm

Browse source
This commit is contained in:
Ramnique Singh 2026-02-18 22:07:54 +05:30
parent d7b423404c
commit 737c3a75b4
1 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
apps/x/packages/core/src/agents/runtime.ts
View file

@ -226,13 +226,14 @@ export class StreamStepMessageBuilder {
private textBuffer: string = "";
private reasoningBuffer: string = "";
private providerOptions: z.infer<typeof ProviderOptions> | undefined = undefined;
private reasoningProviderOptions: z.infer<typeof ProviderOptions> | undefined = undefined;
flushBuffers() {
// skip reasoning
// if (this.reasoningBuffer) {
// this.parts.push({ type: "reasoning", text: this.reasoningBuffer });
// this.reasoningBuffer = "";
// }
if (this.reasoningBuffer || this.reasoningProviderOptions) {
this.parts.push({ type: "reasoning", text: this.reasoningBuffer, providerOptions: this.reasoningProviderOptions });
this.reasoningBuffer = "";
this.reasoningProviderOptions = undefined;
}
if (this.textBuffer) {
this.parts.push({ type: "text", text: this.textBuffer });
this.textBuffer = "";
@ -242,7 +243,11 @@ export class StreamStepMessageBuilder {
ingest(event: z.infer<typeof LlmStepStreamEvent>) {
switch (event.type) {
case "reasoning-start":
break;
case "reasoning-end":
this.reasoningProviderOptions = event.providerOptions;
this.flushBuffers();
break;
case "text-start":
case "text-end":
this.flushBuffers();