RxJava(九)--条件操作符

常用条件操作符

amb、defaultIfEmpty等

实例与功能介绍

1. amb操作符

代码实例

        Observable observable1 = Observable.just(1,2,3).delay(2, TimeUnit.SECONDS);
        Observable observable2 = Observable.just(4,5,6);
        Observable observable = Observable.amb(observable1,observable2);

结果

结果: 4
结果: 5
结果: 6

功能：amb操作符对于给定两个或多个Observable，它只发送首先发送数据或者通知的那个Observable的所有数据。

2. defaultIfEmpty操作符

代码实例

        Observable observable = Observable.create(new Observable.OnSubscribe<Integer>() {
            @Override
            public void call(Subscriber<? super Integer> subscriber) {
                subscriber.onCompleted();
            }
        });
        observable = observable.defaultIfEmpty(7);

结果

结果: 7

功能：如果原始Observable没有发送数据，就发送一个默认数据。