您可以
compose(Func1)用来保持顺序但可以自定义行为
source.compose(o -> condition ? o.map(v -> v + 1) : o.map(v -> v * v)).filter(...).subscribe(...)

您可以
compose(Func1)用来保持顺序但可以自定义行为
source.compose(o -> condition ? o.map(v -> v + 1) : o.map(v -> v * v)).filter(...).subscribe(...)