So umgehen Sie onCompleted

Question

Ich benutze BehaviorSubject, um einen Strom von Ereignissen aus verschiedenen Quellen zu machen. vereinfacht ist, es so aussehen:

BehaviorSubject subject = BehaviorSubject.create(); 
Observable<Integer> src1 = Observable.just(1, 2, 3); 
Observable<Integer> src2 = Observable.just(4, 5, 6); 
Observable<Integer> src3 = Observable.just(7, 8, 9); 
src1.subscribe(subject); 
src2.subscribe(subject); 
src3.subscribe(subject); 
subject.subscribe(this::log); 

In diesem Beispiel Werte von src1 nur angemeldet werden, da nicht mehr Gegenstand Abonnement wird nach src1 Abschluss existiert.

Wie könnte ich Abschluss-Ereignisse von allen Quellen umgehen? Gibt es einen Operator wie ignoreCompleted()?

Answer 1

verwenden, ignoriert onComplete() und onError(): https://github.com/JakeWharton/RxRelay