agent-bot/takt
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

fix: avoid leading-boundary flush before complete boundary

Browse Source
This commit is contained in:
nrslib 2026-03-02 15:14:01 +09:00
parent 872ff5fa36
commit 769bd98724
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/core/piece/engine/stream-buffer.ts
View File

@ -106,6 +106,11 @@ export class LineTimeSliceBuffer {
? boundaryIndex + 1 ? boundaryIndex + 1
: buffer.length; : buffer.length;
if (!canForceFlush && buffer.length > 0 && this.isBoundary(buffer.charAt(0)) && boundaryIndex < 0) {
this.scheduleTimer(key);
return undefined;
}
const flushText = buffer.slice(0, flushIndex); const flushText = buffer.slice(0, flushIndex);
const remainder = buffer.slice(flushIndex); const remainder = buffer.slice(flushIndex);
this.buffers.set(key, remainder); this.buffers.set(key, remainder);