File tree Expand file tree Collapse file tree 3 files changed +12
-10
lines changed
backend/src/main/java/io/f1/backend/domain/game/sse Expand file tree Collapse file tree 3 files changed +12
-10
lines changed Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse ;
22
3- import java .io .IOException ;
43import lombok .RequiredArgsConstructor ;
4+
55import org .springframework .web .bind .annotation .GetMapping ;
66import org .springframework .web .bind .annotation .RequestMapping ;
77import org .springframework .web .bind .annotation .RestController ;
Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse ;
22
3- import java .util .List ;
4- import java .util .concurrent .CopyOnWriteArrayList ;
53import org .springframework .stereotype .Repository ;
64import org .springframework .web .servlet .mvc .method .annotation .SseEmitter ;
75
6+ import java .util .List ;
7+ import java .util .concurrent .CopyOnWriteArrayList ;
8+
89@ Repository
910public class SseEmitterRepository {
1011
@@ -13,9 +14,10 @@ public class SseEmitterRepository {
1314 public void save (SseEmitter emitter ) {
1415 emitters .add (emitter );
1516 // 연결종료 객체정리
16- emitter .onCompletion (() -> {
17- emitters .remove (emitter );
18- });
17+ emitter .onCompletion (
18+ () -> {
19+ emitters .remove (emitter );
20+ });
1921 emitter .onTimeout (() -> emitters .remove (emitter ));
2022 emitter .onError (error -> emitters .remove (emitter ));
2123 }
Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse ;
22
3- import java .io .IOException ;
43import lombok .RequiredArgsConstructor ;
4+
55import org .springframework .stereotype .Service ;
66import org .springframework .web .servlet .mvc .method .annotation .SseEmitter ;
77
8+ import java .io .IOException ;
9+
810@ Service
911@ RequiredArgsConstructor
1012public class SseService {
@@ -17,9 +19,7 @@ public SseEmitter subscribe() {
1719
1820 try {
1921 // emitter 정상 전송확인 메시지
20- emitter .send (SseEmitter .event ()
21- .name ("connect" )
22- .data ("connected" ));
22+ emitter .send (SseEmitter .event ().name ("connect" ).data ("connected" ));
2323 } catch (IOException e ) {
2424 // emitter send() 호출 시 예외 처리
2525 emitterRepository .remove (emitter );
You can’t perform that action at this time.
0 commit comments