RxJava filter 'else'

Question

I want to split my observable like if/else statement

Something like:

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

Is it even possible?

Answer 1

In Observable does not work in that way, you have to think that the observable is just like a stream, where you can end up with some items, u others. The most close if/else that you will find in observables will be use GroupsBy.

Here you have some practicle example that I did explaining how works

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