RxJava操作符实践：7_条件和布尔操作之3_skipUntil

一、描述

丢弃原始Observable发射的数据，直到第二个Observable发射了一项数据。

SkipUntil订阅原始的Observable，但是忽略它的发射物，直到第二个Observable发射了一项数据那一刻，它开始发射原始Observable。

RxJava中对应的是skipUntil，它默认不在任何特定的调度器上执行。

二、示意图

三、示例代码

Observable observable1 = Observable.interval(1000, TimeUnit.MILLISECONDS).take(5);
Observable observable2 = Observable.just(1, 2).delay(2500, TimeUnit.MILLISECONDS);

observable1.skipUntil(observable2)
    .subscribe(new Subscriber<Long>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Long aLong) {
            System.out.println("onNext: " + aLong);
        }
    });

四、运行结果

onNext: 2
onNext: 3
onNext: 4
onCompleted.

1. observable1每隔1秒发一个数据（第1秒时发射0，第2秒时发射1），但是skipUntil并不会把数据发射出来；
2. 直到observable2在2.5秒的时候发射了第1个数据；
3. skipUntil才将observable1后续的所有数据发射出来（2、3、4和完成事件）。

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客