lukeye/doc-parser-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix SSE格式

Browse Source
This commit is contained in:
luke 2025-06-23 16:28:06 +08:00
parent 0901ff78a5
commit 2cd64981a1
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/knowledge/base/infrastructure/util/http/SseOutputAdapter.java
View File

@ -1,6 +1,5 @@
package com.knowledge.base.infrastructure.util.http; package com.knowledge.base.infrastructure.util.http;
import cn.hutool.core.util.StrUtil;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
import java.io.IOException; import java.io.IOException;
@ -15,8 +14,16 @@ public class SseOutputAdapter implements WriterAdapter {
@Override @Override
public void writeLine(String line) throws IOException { public void writeLine(String line) throws IOException {
if (StrUtil.isNotBlank(line)) { if (line == null || line.isBlank()) {
emitter.send(SseEmitter.event().data(line)); return;
} }
// 如果 line 以 "data: " 开头，则去除该前缀
if (line.startsWith("data: ")) {
line = line.substring(6).trim();
}
// 发送单行 SSE 事件
emitter.send(SseEmitter.event().data(line));
} }
} }