데이터 결합 연산자 / merge 관련 질문
445
1 câu hỏi đã được viết
안녕하세요 강사님!! RxJava 강의 열심히 듣고있습니다.
다름이 아니라 Merge 함수를 실행할 때 Observable을 merge() 결합할 때 interval로 설정한 시간만큼 통지시점에 따라 순차적으로 데이터가 통지된다고 하셨는데
제 코드에서는 정상적으로 동작하지 않는 것 같아서 질문 드립니다.
1.결과값을 보면 스레드 할당이 제대로 안되는 것 같은데 merge말고 다른 부분에 문제가 있는 건가요?? 결과값도 실행할 때마다 바뀝니다..
2. 저는 RxJava3 으로 설정해서 사용 중인데 변경된 부분이 있어서 그럴까요?? 공식문서를 찾아봐도 merge에 관한 변경점은 못찾았습니다ㅠㅠ
Câu trả lời 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