This commit is contained in:
luke 2025-06-23 18:34:22 +08:00
parent 09b2db0df3
commit 87198e42e4

View File

@ -46,6 +46,11 @@ public class FilteredSseOutputAdapter implements WriterAdapter {
lastChunk.put("sources", original.get("sources")); lastChunk.put("sources", original.get("sources"));
} }
if(original.containsKey("close")) {
filtered.put("close", original.get("close"));
lastChunk.put("close", original.get("close"));
}
// 最后一条才合并 sources 输出 // 最后一条才合并 sources 输出
if (Boolean.TRUE.equals(original.get("close"))) { if (Boolean.TRUE.equals(original.get("close"))) {
// 合并缓存中的 sources // 合并缓存中的 sources