RxJava操作符实践：7_条件和布尔操作之6_takeWhile

一、描述

发射Observable发射的数据，直到一个指定的条件不成立。

TakeWhile发射原始Observable，直到你指定的某个条件不成立的那一刻，它停止发射原始Observable，并终止自己的Observable。

RxJava中的takeWhile操作符返回一个镜像原始Observable行为的Observable，直到某一项数据你指定的函数返回false那一刻，这个新的Observable发射onCompleted终止通知。

takeWhile默认不在任何特定的调度器上执行。

二、示意图

三、示例代码

Observable.just(1, 2, 3, 4, 5)
    .takeWhile(new Func1<Integer, Boolean>() {
        @Override
        public Boolean call(Integer integer) {
            return integer != 3;
        }
    })
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

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

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

四、运行结果

onNext: 1
onNext: 2
onCompleted.

1. 发射前2个数据的时候，1和2都符合判断条件，即不等于3，takeWhile正常将数据发射出去；
2. 直到发射3的时候，判断条件不成立了，即3是等于3的；
3. takeWhile才将后续的所有数据发射出来（3、4、5和完成事件）。

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客