데이터 결합 연산자 / merge 관련 질문
445
작성한 질문수 1
안녕하세요 강사님!! RxJava 강의 열심히 듣고있습니다.
다름이 아니라 Merge 함수를 실행할 때 Observable을 merge() 결합할 때 interval로 설정한 시간만큼 통지시점에 따라 순차적으로 데이터가 통지된다고 하셨는데
제 코드에서는 정상적으로 동작하지 않는 것 같아서 질문 드립니다.
1.결과값을 보면 스레드 할당이 제대로 안되는 것 같은데 merge말고 다른 부분에 문제가 있는 건가요?? 결과값도 실행할 때마다 바뀝니다..
2. 저는 RxJava3 으로 설정해서 사용 중인데 변경된 부분이 있어서 그럴까요?? 공식문서를 찾아봐도 merge에 관한 변경점은 못찾았습니다ㅠㅠ
답변 1
0
추가 ) interval을 10배 늘려서 실행하니 정상적으로 출력되었습니다. 처리 속도가 빨라서 스레드가 얽히는 건가요??
0
규연님, 안녕하세요? 어제 너무 밤 늦게 질문이 들어온걸 확인해서 답변을 제대로 드리지 못했구요. 오늘 낮에는 업무를 해야해서 불편하시겠지만 밤에 답변 드리도록하겠습니다. ^^;
감사합니다.
0
규연님, 안녕하세요?
RxJava 3.0 버전은 현재 제가 사용해보고 있지는 않은 상태인데 공식 문서 상으로도 특별한 차이점을 현재는 발견하지 못한 상태입니다.
merge 연산자는 마블 다이어그램에서 확인할 수 있다시피 기본적으로 데이터가 통지된 시간을 기준으로 merge가 되는건 맞고, 제 컴퓨터 환경에서는 매번 실행때 마다 데이터가 바뀌는 증상이 있거나 하지는 않습니다.
다만 조금 더 분석해 볼 필요가 있는 부분은 저희 강의가 2.2.x 버전으로 예제 코드가 구성이 된 상태라서 3.x 버전으로 저도 테스트를 한번 해봐야 될 것 같구요.
추가적으로 interval 연산자에서 사용하는 Scheduler에 대해서 조금 더 분석을 해 볼 필요가 있긴할 것 같습니다.
Scheduler의 동작이 실행 환경에 영향을 얼마나 받는지 분석을 해보겠습니다.
시간이 조금 걸릴 것 같은데 이 부분은 우선 건너뛰고 학습을 진행해주시길 바랄게요.
감사합니다.
Single과 관련해 여쭤보고 싶은 부분이 있습니다!
0
264
2
cold/hot publisher 예제 코드와 관련해 질문 드립니다.
0
363
1
CompletableObserver 클래스의 람다식 표현관련
0
297
1
1강에 예시로 보여주신 ToDoSample 코드에 관해 질문 드립니다!
0
356
1
DROP 배압 전략에 관한 궁금증
0
300
2
map에서의 TimeUtil.sleep에 관한 궁금점
0
216
1
강의 내용을 정리해서 개인 블로그에 올려도 될까요?
0
562
2
TimeUtil.sleep 관련 질문
0
286
1
배압 전략 중에서 DROP 전략과 관련해서 질문 있습니다.
0
335
1
Error 발생 시에도 계속 처리 방법
0
689
2
선언형 프로그래밍과 명령형 프로그래밍
1
784
2
첫번째 강의 부터 이번강의까지 수강하면서 궁금한점 질문드립니다.
0
325
1
안녕하세요. 질문이 있습니다.
1
354
1
logger 가 없는데 util 폴더도 같이 갖다놔야 하나요?
0
327
1
amb 연산자
0
233
1
질문 드립니다.
0
219
1
concatEager( ) 연산자에 관하여
0
318
1
Reactive Streams의 구성요소들과 RxJava의 구성요소들의 관계?
1
397
2
ObservableSequenceEqualExample.java 예제의 delay( ) 연산자 질문있습니다
0
309
3
defer( ), fromFuture( )도 just( )처럼 여러 인자 값을 받을 수 있는지 궁금합니다.
0
264
3
flatMapSingle() 메소드에 대하여
0
620
6
fromFuture() vs fromCallable() 생성 연산자에 대해
0
573
2
함수형 인터페이스 Comparator에 대해
0
397
2
Publisher와 Subscriber 간의 프로세스 흐름에 대한 질문
1
340
3