Android之Rxjava2.X 7————Rxjava 条件操作符

刺骨的言语ヽ痛彻心扉 2022-05-16 04:08 389阅读 0赞

# Android之Rxjava2.X 7————Rxjava 条件操作符 #

### 一. 目录 ###

### 文章目录 ###

*  Android之Rxjava2.X 7————Rxjava 条件操作符
 *   *   *  一. 目录
         *  二. 概述
         *   *  1.作用
             *  2.类型
         *  三. 具体操作符详解
         *   *  1.all（）
             *  2.takeWhile（）
             *  3.skipWhile（）
             *  4.takeUntil（）
             *  5.skipUntil（）
             *  6.SequenceEqual（）
             *  7.contains（）
             *  8.isEmpty（）
             *  9.amb（）
             *  10.defaultIfEmpty（）
         *  四. 参考资料
         *  五.文章索引

### 二. 概述 ###

#### 1.作用 ####

通过设置函数，判断被观察者（Observable）发送的事件是否符合条件

#### 2.类型 ####

![这里写图片描述][700]

### 三. 具体操作符详解 ###

#### 1.all（） ####

作用：判定是否Observable发射的所有数据都满足某个条件  
![这里写图片描述][all.png]

具体使用：

private void rxJavaDemo10() {
         
            Observable.just(1, 2, 3, 4, 5).
                    all(new Predicate<Integer>() {
         
                @Override
                public boolean test(Integer integer) throws Exception {
         
                    return integer <= 10;
                }
            }).subscribe(new Consumer<Boolean>() {
         
                @Override
                public void accept(Boolean aBoolean) throws Exception {
         
                    Log.d(TAG, "accept: "+aBoolean);
                }
            });
    
    
        }

![这里写图片描述][20180815121430624]

#### 2.takeWhile（） ####

*  作用：发射Observable发射的数据，直到一个指定的条件不成立

原理图：  
![这里写图片描述][takeWhile.c.png]

具体使用

Observable.just(1, 2, 3, 4, 5)
                    .takeWhile(new Predicate<Integer>() {
         
                        @Override
                        public boolean test(Integer integer) throws Exception {
         
                             return (integer!=3);
                        }
                    }).subscribe(new Consumer<Integer>() {
         
                @Override
                public void accept(Integer integer) throws Exception {
         
                    Log.d(TAG, "accept: "+integer);
    
                }
            });

![这里写图片描述][20180815150450316]

#### 3.skipWhile（） ####

*  作用:丢弃Observable发射的数据，直到一个指定的条件不成立

原理图:  
![这里写图片描述][skipWhile.c.png]

具体使用

Observable.just(1, 2, 3, 4, 5)
                    .skipWhile(new Predicate<Integer>() {
         
                        @Override
                        public boolean test(Integer integer) throws Exception {
         
                             return (integer!=3);
                        }
                    }).subscribe(new Consumer<Integer>() {
         
                @Override
                public void accept(Integer integer) throws Exception {
         
                    Log.d(TAG, "accept: "+integer);
    
                }
            });

![这里写图片描述][20180815151055596]

#### 4.takeUntil（） ####

*  作用1：takeUntil（new Predicate） 执行到某个条件时，停止发送事件
 *  作用2：takeUntil（new Observer） takeUntil（） 传入的Observable开始发送数据，（原始）第1个Observable的数据停止发送数据

原理图  
![这里写图片描述][takeUntil.p.png]  
![这里写图片描述][takeUntil.png]  
具体使用1:

Observable.just(1, 2, 3, 4, 5)
                    .takeUntil(new Predicate<Integer>() {
         
                        @Override
                        public boolean test(Integer integer) throws Exception {
         
                             return (integer==3);
                        }
                    }).subscribe(new Consumer<Integer>() {
         
                @Override
                public void accept(Integer integer) throws Exception {
         
                    Log.d(TAG, "accept: "+integer);
    
                }
            });

![这里写图片描述][20180815151648749]

具体使用2

Observable.interval(1, TimeUnit.SECONDS)
                    // 第2个Observable：延迟5s后开始发送1个Long型数据
                    .takeUntil(Observable.timer(5, TimeUnit.SECONDS))
                    .subscribe(new Consumer<Long>() {
         
                        @Override
                        public void accept(Long integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][20180815152332358]

#### 5.skipUntil（） ####

*  作用：等到 skipUntil（） 传入的Observable开始发送数据，（原始）第1个Observable的数据才开始发送数据

原理图:  
![这里写图片描述][skipUntil.c.png]

具体使用

Observable.interval(1, TimeUnit.SECONDS)
                    // 第2个Observable：延迟5s后开始发送1个Long型数据
                    .skipUntil(Observable.timer(5, TimeUnit.SECONDS))
                    .subscribe(new Consumer<Long>() {
         
                        @Override
                        public void accept(Long integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][20180815152541427]

#### 6.SequenceEqual（） ####

*  作用：判定两个Observables是否发射相同的数据序列。若相同，返回 true；否则，返回 false

原理图：  
![这里写图片描述][sequenceEqual.c.png]

具体使用：

Observable
                    .sequenceEqual(Observable.just(1,2,3,4),Observable.just(1,2,3,4))
                    .subscribe(new Consumer<Boolean>() {
         
                        @Override
                        public void accept(Boolean integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][20180815153527943]

#### 7.contains（） ####

*  作用：判断发送的数据中是否包含指定数据

原理图：  
![这里写图片描述][contains.png]

具体使用

Observable.just(1, 2, 3, 4, 5, 6)
                    .contains(4)
                    .subscribe(new Consumer<Boolean>() {
         
                        @Override
                        public void accept(Boolean integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][20180815153942568]

#### 8.isEmpty（） ####

*  作用:判断发送的数据是否为空

原理图：  
![这里写图片描述][isEmpty.png]

具体使用

Observable.just(1, 2, 3, 4, 5, 6)
                    .isEmpty()
                    .subscribe(new Consumer<Boolean>() {
         
                        @Override
                        public void accept(Boolean integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][20180815154127901]

#### 9.amb（） ####

*  作用:当需要发送多个 Observable时，只发送 先发送数据的Observable的数据，而其余 Observable则被丢弃。

原理图：  
![这里写图片描述][amb.png]

具体使用

List<ObservableSource<Integer>> list= new ArrayList <>();
            list.add( Observable.just(1,2,3).delay(1,TimeUnit.SECONDS));
            list.add( Observable.just(4,5,6));
    
            Observable.amb(list)
                    .subscribe(new Consumer<Integer>() {
         
                        @Override
                        public void accept(Integer integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

#### 10.defaultIfEmpty（） ####

*  作用: 在不发送任何有效事件（ Next事件）、仅发送了 Complete 事件的前提下，发送一个默认值

原理图：  
![这里写图片描述][defaultIfEmpty.c.png]

具体使用

Observable.create(new ObservableOnSubscribe<Integer>() {
         
                @Override
                public void subscribe(ObservableEmitter<Integer> e) throws Exception {
         
                    e.onComplete();
                }
            }).defaultIfEmpty(10)
                    .subscribe(new Consumer<Integer>() {
         
                        @Override
                        public void accept(Integer integer) throws Exception {
         
                            Log.d(TAG, "accept: " + integer);
    
                        }
                    });

![这里写图片描述][70]

### 四. 参考资料 ###

[Rxjava中文文档][Rxjava]  
[Android RxJava2(六)条件操作符][Android RxJava2]  
[Android RxJava：详解 条件 / 布尔操作符][Android RxJava_ _ _]

### 五.文章索引 ###

*  [Android之Rxjava2.X 1————Rxjava概述][Android_Rxjava2.X 1_Rxjava]
 *  [Android之Rxjava2.X 2————Rxjava 创建操作符][Android_Rxjava2.X 2_Rxjava]
 *  [Android之Rxjava2.X 3————Rxjava 变换操作符][Android_Rxjava2.X 3_Rxjava]
 *  [Android之Rxjava2.X 4————Rxjava 组合操作符][Android_Rxjava2.X 4_Rxjava]
 *  [Android之Rxjava2.X 5————Rxjava 过滤操作符][Android_Rxjava2.X 5_Rxjava]
 *  [Android之Rxjava2.X 6————Rxjava 功能操作符][Android_Rxjava2.X 6_Rxjava]
 *  [Android之Rxjava2.X 7————Rxjava 条件操作符][Android_Rxjava2.X 7_Rxjava]
 *  [Android之Rxjava2.X 8————Rxjava 背压策略][Android_Rxjava2.X 8_Rxjava]
 *  [Android之Rxjava2.X 9————Rxjava源码阅读1][Android_Rxjava2.X 9_Rxjava_1]
 *  [Android之Rxjava2.X 10————Rxjava源码阅读2][Android_Rxjava2.X 10_Rxjava_2]
 *  [Android之Rxjava2.X 11————Rxjava源码阅读3][Android_Rxjava2.X 11_Rxjava_3]

[700]: /images/20220516/ccf87ce18c4b41e09b46f85f67d9ebc4.png
[all.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/all.png
[20180815121430624]: /images/20220516/bf43c2ecc1654a2f997f53271d05ebbc.png
[takeWhile.c.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/takeWhile.c.png
[20180815150450316]: /images/20220516/9aab35ad768844d8a06ca5fc22c041ca.png
[skipWhile.c.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/skipWhile.c.png
[20180815151055596]: /images/20220516/1c293ba7e9c44f89b9c0480c18279ee8.png
[takeUntil.p.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/takeUntil.p.png
[takeUntil.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/takeUntil.png
[20180815151648749]: /images/20220516/1e2f4964115749d09c2aab89f4a1da76.png
[20180815152332358]: /images/20220516/0d54b60e3fd7409fb708d3f9eee3826c.png
[skipUntil.c.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/skipUntil.c.png
[20180815152541427]: /images/20220516/0379b7d495c94e768ccc4ee05bfa2364.png
[sequenceEqual.c.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/sequenceEqual.c.png
[20180815153527943]: /images/20220516/49203bca60e148299ea6a6c7de7c3daf.png
[contains.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/contains.png
[20180815153942568]: /images/20220516/68d9af35f98848428367836127ccc8de.png
[isEmpty.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/isEmpty.png
[20180815154127901]: /images/20220516/e7ae488055b247fe854cc0ff88f79d9b.png
[amb.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/amb.png
[defaultIfEmpty.c.png]: https://mcxiaoke.gitbooks.io/rxdocs/content/images/operators/defaultIfEmpty.c.png
[70]: /images/20220516/604f92256fce4f63a98196e38f72dfd8.png
[Rxjava]: https://mcxiaoke.gitbooks.io/rxdocs/content/operators/Conditional.html
[Android RxJava2]: https://blog.csdn.net/mixin716/article/details/80624445
[Android RxJava_ _ _]: https://www.jianshu.com/p/954426f90325
[Android_Rxjava2.X 1_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81611870
[Android_Rxjava2.X 2_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81637932
[Android_Rxjava2.X 3_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81668545
[Android_Rxjava2.X 4_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81670980
[Android_Rxjava2.X 5_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81675322
[Android_Rxjava2.X 6_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81700187
[Android_Rxjava2.X 7_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81705745
[Android_Rxjava2.X 8_Rxjava]: https://blog.csdn.net/qq_38499859/article/details/81747334
[Android_Rxjava2.X 9_Rxjava_1]: https://blog.csdn.net/qq_38499859/article/details/81775520
[Android_Rxjava2.X 10_Rxjava_2]: https://blog.csdn.net/qq_38499859/article/details/81839955
[Android_Rxjava2.X 11_Rxjava_3]: https://blog.csdn.net/qq_38499859/article/details/82119900