zyx преди 1 година
родител
ревизия
92ea19d6b3
променени са 1 файла, в които са добавени 2 реда и са изтрити 2 реда
  1. 2 2
      src/main/java/com/sxtvs/open/api/review/controller/SseController.java

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

@@ -39,13 +39,13 @@ public class SseController {
         logger.debug("msg", "3");
         sseService.monitor(token, sseEmitter);
         logger.debug("msg", "4");
-        sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
         poolExecutor.execute(() -> {
             try {
+                logger.debug("msg", "6");
                 Thread.sleep(1000);
                 sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
                 Thread.sleep(1000);
-                sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
+                logger.debug("msg", "7");
             } catch (Exception e) {
                 logger.error("error", e);
             }