FlatMapとサブジェクト - サブスクライバーの複製を避けるにはどうすればよいですか？

Question

のは、私は次のコードを持っているとしましょう：それは生産

BehaviorSubject<Integer> subject = BehaviorSubject.create(); 
BehaviorSubject<Integer> subject2 = BehaviorSubject.create(); 
subject. 
     doOnNext(number -> subject2.onNext(number)). 
     flatMap(number -> subject2). 
     subscribe(number -> System.out.println("Number " + number)); 

for(int i = 0; i < 10; i++) { 
    subject.onNext(i); 
} 

出力は次のようになります。

Number 0 
Number 1 
Number 1 
Number 2 
Number 2 
Number 2 
Number 3 
Number 3 
Number 3 
Number 3 
Number 4 
Number 4 
Number 4 
Number 4 
Number 4 

を、オン、オン。

なぜそれが起こるのか理解します。それは、flatMapが呼び出されるたびに、新しいサブスクライバがsubject2に追加されるためです。

質問です - これを避ける方法は？

Answer 1

あなたはこのようflatMap内の一つの要素にsubject2を制限することができます。

flatMap(number -> subject2.first())

コード

BehaviorSubject<Integer> subject = BehaviorSubject.create(); 
    BehaviorSubject<Integer> subject2 = BehaviorSubject.create(); 
    subject. 
      doOnNext(number -> subject2.onNext(number)). 
      flatMap(number -> subject2.first()). 
      subscribe(number -> System.out.println("Number " + number)); 

    for(int i = 0; i < 10; i++) { 
     subject.onNext(i); 
    } 

がswitchMap代わりのflatMapを試し重複

Answer 2

が含まれていない出力を生成します。

switchMapは、受信した最後のObservableにしか登録されていません。それ以前に購読したすべての購読者からの購読を取り消します。Observable

http://reactivex.io/RxJava/javadoc/rx/Observable.html#switchMap