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(...)