RxJava Filter 'else'

Question

Ich möchte meine beobachtbar wie if/else Aussage

So etwas spalten:

A[] array = new A[10]; 
for (int i = 0; i < array.length; i++) { 
    array[i] = new A(getRandomString(), getRandomInt()); 
} 

Observable.from(array) 
    .filter(a -> condition(a)) 
     .// <--- do stuff if condition returns true 
     .// <- back to parent 
    .filter(a -> complexCondition(a)) // filter all elements(!) 
     .// <--- do stuff if complex condition returns true 
     .// <- back to iterate all elements 

Ist es überhaupt möglich?

Answer 1

In Observable funktioniert nicht auf diese Weise, müssen Sie denken, dass das Observable ist genau wie ein Stream, wo Sie mit einigen Elementen, u anderen enden können. Die naheste if/else, die Sie in Observables finden, ist die Verwendung von GroupsBy.

Hier haben Sie einige practicle Beispiel, dass ich habe zu erklären, wie funktioniert

https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/transforming/ObservableGroupBy.java

Answer 2

Eine Möglichkeit, dieses Verhalten zu erreichen, zweimal, um Ihre Daten zu abonnieren und filtern anders:

Subscription subscriptionA = Observable.from(array) 
    .filter(a -> condition(a)) 
    .subscribe(...) // <-- do stuff for condition A 

Subscription subscriptionB = Observable.from(array) 
    .filter(a -> complexCondition(a)) 
    .subscribe(...) // <-- do stuff for condition B 

Answer 3

Um auf Ken's answer zu erweitern, besteht eine andere Möglichkeit darin, das Observable in die zwei Zweige zu verzweigen, unter Verwendung der replay operator. Dies garantiert, dass das ursprüngliche Observable nur einmal aufgerufen wird. Dies ist nützlich, wenn es einige teure Verarbeitung oder Nebenwirkungen irgendwo in der Kette ist:

ConnectableObservable<A> connectable = Observable.fromArray() 
    .replay(); 

connectable 
    .filter(a -> condition(a)) 
    .// <--- do stuff if condition returns true 

connectable.connect(); // do this after the first branch 

connectable 
    .filter(a -> complexCondition(a)) // filter all elements(!) 
    .// <--- do stuff if complex condition returns true 

connectable 
    .// <- iterate all elements 

Denken Sie daran, dass alle Zweige sowohl die OnNext behandeln müssen und die onError Ereignisse.