amb 연산자
233
投稿した質問数 4
예제에서 amb 연산자에 입력값 observable 중에서 두번째, 세번째 observable은 메시지 발행 자체를 안하는걸까요?
amb 연산자 다이어그램과 예제를 보고 출력결과를 예상했을 때, 두번째, 세번째 observable의 데이터가 amb() 소비자에게 전달만 안될 뿐이지, 데이터를 발행하고 종료가 되면 doOnComplete()에 있는 로그가 찍히지 않을까 생각했었거든요.
# branch A's sales
# 완료
# branch B's sales
# branch C's sales
이런식으로 로그가 찍힐거라고 예상했었어요. 제가 어떤 부분을 잘못 생각하고 있는걸까요?
回答 1
2
윤정님, 안녕하세요?
좋은 질문을 해주셨어요.
윤정님, 말씀대로 amb 마블 다이어그램이 두번째, 세번째 Observable도 Downstream 에 데이터를 통지를 하지만 전달은 되지 않고 무시가 되는것처럼 그려져 있네요. 제 생각에는 마블 다이어그램이 잘못 그려져있는것 같다라는 생각이 들어서 RxJava 3.x 문서를 좀 찾아보았더니 2.x 와는 다르게 아래처럼 정정이 되어 있었습니다.
마블 다이어 그램을 보시면 노란색 동그라미가 포함된 Observable에서 노란색 동그라미가 통지가 되면 나머지 Observable 들은 dispose()가 호출되어서 데이터 통지가 취소되는것을 볼 수 있습니다.
이건 제가 강의에서 놓친 부분인데 잘 지적해주셨네요. 올바르게 다시 설명 드릴 수 있어서 다행입니다.
다른 질문 있으시면 또 글 남겨주세요.
감사합니다.
Single과 관련해 여쭤보고 싶은 부분이 있습니다!
0
264
2
cold/hot publisher 예제 코드와 관련해 질문 드립니다.
0
363
1
CompletableObserver 클래스의 람다식 표현관련
0
297
1
1강에 예시로 보여주신 ToDoSample 코드에 관해 질문 드립니다!
0
356
1
데이터 결합 연산자 / merge 관련 질문
0
445
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
질문 드립니다.
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