RxJava:Hvordan man betinget anvender operatører på en observerbar uden at bryde kæden

Du kan bruge compose(Func1) at forblive i rækkefølge, men udføre tilpasset adfærd

source
.compose(o -> condition ? o.map(v -> v + 1) : o.map(v -> v * v))
.filter(...)
.subscribe(...)