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