RxJava：如何有条件地将运算符应用于Observable而不中断链

RxJava：如何有条件地将运算符应用于Observable而不中断链

您可以

compose(Func1)

用来保持顺序但可以自定义行为

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