小编xym*_*lon的帖子

我有一组并行执行的可观察对象，例如localObservable和networkObservable。如果networkObservable开始发射物品（从现在开始，我只需要这些物品），则丢弃发射的物品localObservable（也许localObservable尚未开始）。

Observable<Integer> localObservable =
            Observable.defer(() -> Observable.range(1, 10)).subscribeOn(Schedulers.io());
Observable<Integer> networkObservable =
            Observable.defer(() -> Observable.range(11, 20)).subscribeOn(Schedulers.io());