|
@@ -42,7 +42,7 @@ public class SseController {
|
|
SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
|
|
SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
|
|
sseService.monitor(kimiChat.getGroupId(), sseEmitter);
|
|
sseService.monitor(kimiChat.getGroupId(), sseEmitter);
|
|
kimiChatService.create(kimiChat);
|
|
kimiChatService.create(kimiChat);
|
|
- sseEmitter.send(SseEmitter.event().name("data").data(" "));
|
|
|
|
|
|
+ sseEmitter.send(SseEmitter.event().name("data").data("hello"));
|
|
|
|
|
|
return sseEmitter;
|
|
return sseEmitter;
|
|
}
|
|
}
|