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

可以限制subject2一個元素中flatMap這樣的：

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); 
    } 

產生不包含重複

Answer 2

嘗試switchMap而不是flatMap輸出。

switchMap只會訂閱最後收到的Observable。它退訂所有以前訂閱的Observable。

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