Skip to content

P
poc-api
Commit b0e49801 authored by alex yao's avatar alex yao
Browse files
Options

feat: SSE客户端断开感知

parent 4c53c2a3
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
src/main/java/cn/com/poc/agent_application/aggregate/impl/AgentApplicationInfoServiceImpl.java
View file @ b0e49801
...@@ -824,13 +824,13 @@ public class AgentApplicationInfoServiceImpl implements AgentApplicationInfoServ ...@@ -824,13 +824,13 @@ public class AgentApplicationInfoServiceImpl implements AgentApplicationInfoServ
sseUtil.complete(); sseUtil.complete();
throw ex; throw ex;
} }
sseUtil.send(res);
if (StringUtils.isNotEmpty(result.getMessage())) { if (StringUtils.isNotEmpty(result.getMessage())) {
output.append(result.getMessage()); output.append(result.getMessage());
} }
if (StringUtils.isNotEmpty(result.getReasoningContent())) { if (StringUtils.isNotEmpty(result.getReasoningContent())) {
reasoningContent.append(result.getReasoningContent()); reasoningContent.append(result.getReasoningContent());
} }
sseUtil.send(res);
} }
bufferedReader.close(); bufferedReader.close();
// 关闭资源 // 关闭资源
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment