File tree Expand file tree Collapse file tree 3 files changed +14
-9
lines changed
backend/src/main/java/io/f1/backend/domain/game/sse Expand file tree Collapse file tree 3 files changed +14
-9
lines changed Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse .api ;
22
33import io .f1 .backend .domain .game .sse .app .SseService ;
4+
45import lombok .RequiredArgsConstructor ;
6+
57import org .springframework .web .bind .annotation .GetMapping ;
68import org .springframework .web .bind .annotation .RequestMapping ;
79import org .springframework .web .bind .annotation .RestController ;
Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse .app ;
22
33import io .f1 .backend .domain .game .sse .store .SseEmitterRepository ;
4- import java . io . IOException ;
4+
55import lombok .RequiredArgsConstructor ;
6+
67import org .springframework .stereotype .Service ;
78import org .springframework .web .servlet .mvc .method .annotation .SseEmitter ;
89
10+ import java .io .IOException ;
11+
912@ Service
1013@ RequiredArgsConstructor
1114public class SseService {
@@ -18,9 +21,7 @@ public SseEmitter subscribe() {
1821
1922 try {
2023 // emitter 정상 전송확인 메시지
21- emitter .send (SseEmitter .event ()
22- .name ("connect" )
23- .data ("connected" ));
24+ emitter .send (SseEmitter .event ().name ("connect" ).data ("connected" ));
2425 } catch (IOException e ) {
2526 // emitter send() 호출 시 예외 처리
2627 emitterRepository .remove (emitter );
Original file line number Diff line number Diff line change 11package io .f1 .backend .domain .game .sse .store ;
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 }
You can’t perform that action at this time.
0 commit comments