예제에서 Runnable 용도
230
32 asked
안녕하세요.
dispose 함수에 Runnable 객체가 전달되는데, emitter 완료와 타임아웃 때 처리되는 로직이 runnable로 만 처리해야 하는 건가요?
아직 rx 프로그래밍에 대한 경험이 없다보니 예제 코드가 관례적인 것인지 아닌지 판단하기 어렵습니다.
Answer 1
0
안녕하세요. 대체 휴일이 끼어있다보니 답변이 좀 늦었습니다.
가족하고 함께 해야 되는 시간이 있다보니 답변이 더 늦어진 점 양해 부탁드리겠습니다.
질문하신 부분에 대해서 답변을 드려보자면,
"dispose 함수에 Runnable 객체가 전달되는데, emitter 완료와 타임아웃 때 처리되는 로직이 runnable로 만 처리해야 하는 건가요?"
--> runnable만 처리하라는 법은 없겠지만 제가 만든 예제 상으로는 SseEmitter 의 onCompletion 메서드의 경우에는 runnable을 파라미터로 전달 받아서 후속 처리를 하도록 API에 정의가 되어 있기때문에 관례적으로 사용을 한건 맞습니다. 예제 코드의 흐름 상 세션이 종료될 때 구독을 해지 해주는것이 리소스를 효율적으로 사용하게 만들어줄테니까요. 저는 구독 해지를 세션이 종료 되는 경우에 사용을 했지만 구독 해지는 애플리케이션의 요구사항에 따라서 구독 해지의 상황이 달라질테니 적절하게 대응을 하시면 될 것 같아요.
다른 질문이 있으시면 언제든지 질문 해주시면 감사드리겠습니다.
Single과 관련해 여쭤보고 싶은 부분이 있습니다!
0
264
2
cold/hot publisher 예제 코드와 관련해 질문 드립니다.
0
363
1
CompletableObserver 클래스의 람다식 표현관련
0
297
1
1강에 예시로 보여주신 ToDoSample 코드에 관해 질문 드립니다!
0
356
1
[질문] cascading operator 설명하실 때
2
614
1
_get 함수 부분이 너무 이해가 안갑니다 ㅠ
0
656
2
초급자 질문
0
501
1
CachedNetworkImage 로 인한 memory leak 문제..
0
943
2
병렬평가 질문 있습니다!
0
428
1
함수를 분리하지 않고 실행하게 되면 순환참조 오류가 발생합니다...
0
621
1
rxjs 와 차이점
0
567
1
거르기 함수 중 compact 질문드립니다.
0
475
1
return 있고 없고 차이 질문드립니다...!
0
1062
3
강의 잘봤습니당
0
452
1
이것이 왜 실행이 안되는지 여쭙고 싶네요.
0
2792
1
초급강의를 수강할때 질문입니다.
0
469
1
실무에서 SSE 서비스 구성 시 컴포넌트와 아키텍처 문의
0
421
1
doOnComplete, doOnError 는 왜 필요한가요?
0
807
1
스프링 웹플럭스 강의는 안하시나요?
0
1232
1
Schedulers.computation()에 관하여
0
471
5
조금 더 자세한 설명부탁드립니다
0
316
2
DoOnDisposeExample 예제에서의 스레드 관련 질문 (자문자답)
0
224
1
SSE 실습 소스코드 위치 문의
1
486
1
blockingXXXX 함수들은 테스트용도로만 사용하는건가요?
2
224
1