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