feat: enable stream_event forwarding for serve mode streaming
QueryEngine previously guarded stream_event yields behind includePartialMessages, which was undefined in serve mode. Remove the guard so stream_event messages always flow to the child process stdout. Add stream_event handling in sessionHandle.routeMessage to emit via EventBus for downstream consumers.
This commit is contained in:
parent
862a16c295
commit
e37e9d3ad5
|
|
@ -837,14 +837,12 @@ export class QueryEngine {
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (includePartialMessages) {
|
yield {
|
||||||
yield {
|
type: 'stream_event' as const,
|
||||||
type: 'stream_event' as const,
|
event,
|
||||||
event,
|
session_id: getSessionId(),
|
||||||
session_id: getSessionId(),
|
parent_tool_use_id: null,
|
||||||
parent_tool_use_id: null,
|
uuid: randomUUID(),
|
||||||
uuid: randomUUID(),
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
break
|
break
|
||||||
|
|
|
||||||
|
|
@ -521,6 +521,11 @@ export class SessionHandle {
|
||||||
this.pendingQuestions.delete(cancelRequestId)
|
this.pendingQuestions.delete(cancelRequestId)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
case 'stream_event': {
|
||||||
|
this.lastActiveAt = Date.now()
|
||||||
|
this.emitEvent('stream_event', msg)
|
||||||
|
break
|
||||||
|
}
|
||||||
default: {
|
default: {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user