vrr/conduit
2
0
Fork 0
mirror of https://github.com/cogwheel0/conduit.git synced 2026-08-27 03:21:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: reconcile terminal projection when plain chunks ended the stream

Browse source 
finalizeStructuredOutputProjection bailed whenever a plain chunk was the
last content-affecting operation. The terminal snapshot render is
authoritative upstream (output replaces content wholesale in Chat.svelte);
adopt it unless the accumulated visible text is longer, preserving
delta-only hybrid streams.

The done-signal log now records message/rendered/plain lengths so a
truncation report can be pinpointed from one log line.
This commit is contained in:
cogwheel 2026-08-17 19:53:22 +05:30
parent fe030cce02
commit 349bb70803
1 changed files with 17 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

19
lib/core/services/streaming_helper.dart
View file

@ -1107,9 +1107,19 @@ ActiveChatStream attachUnifiedChunkedStreaming({
}
void finalizeStructuredOutputProjection() {
if (!structuredOutputIsLatest) return;
final projection = structuredOutputProjector.finish();
if (projection == null) return;
if (!structuredOutputIsLatest) {
// A plain chunk was the last content-affecting operation and no output
// snapshot followed it. Upstream (Chat.svelte) treats every output
// snapshot as a wholesale replacement of content, so the terminal
// render is authoritative; keep the accumulated visible text only when
// it is longer (hybrid backends deliver some text solely through plain
// deltas the snapshot never contains).
if (projection.plainContent.length < plainStreamingContent.length) {
return;
}
}
if (projection.content == renderedStreamingContent.value) {
plainStreamingContent.replace(projection.plainContent);
return;
@ -3021,7 +3031,12 @@ ActiveChatStream attachUnifiedChunkedStreaming({
last.codeExecutions.isNotEmpty ||
last.sources.isNotEmpty;
DebugLogger.log(
'Done signal received: content length=${lastContent.length}',
// Content audit: on a healthy completion these lengths agree (modulo
// details wrappers). message < rendered pinpoints a lost flush;
// rendered < plain pinpoints an unrepaired deferred projection.
'Done signal received: content length=${lastContent.length} '
'rendered=${renderedStreamingContent.length} '
'plain=${plainStreamingContent.length}',
scope: 'streaming/helper',
);
if (allowEmptyContentRecovery &&