commit

src/main/java/com/sxtvs/open/api/review/controller/SseController.java

@@ -36,8 +36,7 @@ public class SseController {
     public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
         SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
         sseService.monitor(token, sseEmitter);
-        sseEmitter.send(SseEmitter.event().name("data").data("data"));
-        sseEmitter.complete();
+        sseEmitter.send("data");
         return sseEmitter;
     }
 
@@ -50,8 +49,7 @@ public class SseController {
         SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(kimiChat.getGroupId(), sseEmitter);
         kimiChatService.create(kimiChat);
-        sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
-        sseEmitter.complete();
+        sseEmitter.send("data");
         return sseEmitter;
     }