Rx系列之Rxjava操作符进阶-使用场景

通过上一篇《Rx系列之RxJava操作符》，相信已经能够熟练的使用一些基本的操作符了。但是对于我们大家而言，其实最传统的命令式编程已经是我们顺手就可以拈来的，但是，现在用响应式编程，突然发现：卧槽，这个地方用响应式怎么写，这样写对么？估计很多人才开始接触RxJava的时候应该都有这样的疑虑。不用担心，这一篇就给大家讲讲RxJava到底该怎么用，在什么情况下用！

RxJava的使用场景

眼尖的小伙伴，可能已经发现，在上一篇中，很多那么重要的操作符怎么都没讲！哈哈哈，答案在这里。好废话不多说，来看看Rxjava到底在哪些情况下可以使用。

动态搜索的场景

我们先来看一个动态搜索的场景：

搜索

假设，我要在这进行网络搜索，那么，我就要在这里面进行网络访问，如果是输入完成之后点击确定进行搜索还好，但是如果是动态收索呢？只要搜索框中的搜索内容一改变，那么是不是就要进行网络请求呢？那这样就不是那么友好了。为了解决这样的问题，rxjava为我们提供了一个很好的解决方案：

• 使用debounce作为textSearch
  debounce()函数过滤掉由Observable发射的速率过快的数据；如果在一个指定的时间间隔过去了仍旧没有发射一个，那么它将发射最后的那个。
  debounce()使用TimeUnit对象指定时间间隔。
  是不是感觉棒棒哒，昂，不管你喜不喜欢，反正我是爱死它了。

来看一下示意图

输入合法示意图

在这个场景中，我们得掌握两个操作符：skip和combineLatest

skip
抑制Observable发射的前N项数据

哦豁

那这个该怎么办呢？
解决方法有如下两个：

• 采用定时进行清除本地缓存数据
• 采用过滤操作符

我们先来看看第一种，如果是进行定时做本地数据清空的话，那么就会用到，我们一个轮询的操作符Interval
创建一个按固定时间间隔发射整数序列的Observable
Interval通俗的讲，就是每隔一段时间过后做什么事情！上一篇已经讲过了，所以这里就不详细讲解了，直接上代码：

        Observable.interval(3, TimeUnit.SECONDS).subscribe(new Observer<Long>() {
           ...
           @Override
           public void onNext(Long aLong) {
                //清除缓存操作
           }
       });

很多人可能会想到，那既然，我能够用清除本地缓存的方法，那么能不能用，每隔一段时间进行请求，让请求的结果与本地缓存进行合并呢？
答案是肯定的，来看如下代码：

    Observable.create(new Observable.OnSubscribe<String>() {  
            @Override  
           public void call(final Subscriber<? super String> observer) {  
 
              Schedulers.newThread().createWorker()  
                    .schedulePeriodically(new Action0() {  
                          @Override  
                          public void call() {  
                              observer.onNext(doNetworkCallAndGetStringResult());  
                         }  
                      }, INITIAL_DELAY, POLLING_INTERVAL, TimeUnit.MILLISECONDS);  
            }  
        }).subscribe(new Action1<String>() {  
           @Override  
           public void call(String s) {  
               
           }  
      })  

这个就是使用schedulePeriodically做轮询请求

这样造成每过一定时间我们就会，清除缓存或者网络请求。读到这儿，是不是感觉这个方法真烂，哈哈哈，不着急，我们不是还有第二种方法嘛！来接着看第二种方法

• 采用过滤操作符
  其实这个操作符我们已经讲过了，那就是操作符first，回顾一下上面的代码，就是我们的first就是保证，众多的数据，有一个符合条件就发射数据，后面的都将不执行。我们的是否需要更新的条件不加在这里，就没天理咯！

Observable source = Observable
    .concat(memory, disk, network)
    .first(new Func1() {
      @Override public Boolean call(Data data) {
        return data.isUpToDate();
      }
    });

哇偶，这个操作符完美的解决了如上的问题！那你丫的还将那么多，呵呵，我只是给大家讲解操作符的使用场景而已，那个适合哪个场景，取决你们自己咯！

这一篇主要讲解的内容的就到这儿了，下面还有一些其他的场景，就简单的介绍一下。

其他的场景

合并两个数据源场景

使用merge合并两个数据源，代码如下：

    Observable.merge(getInfoFromFile(), getInfoFromNet())  
           .observeOn(AndroidSchedulers.mainThread())  
              .subscribe(new Subscriber<String>() {  
                  @Override  
                  public void onCompleted() {  
                     Log.d(TAG, "onCompleted: onCompleted");
                 }  
 
                 @Override  
                  public void onError(Throwable e) {  
                    Log.d(TAG, "onError: onError");
                  }  
  
                  @Override  
                  public void onNext(String data) {  
                       Log.d(TAG, "onNext: only one ! ");
             });  

Retrofit结合RxJava场景

这个场景的话，大家可以查看扔物线大神写的给 Android 开发者的 RxJava 详解，其中讲解到了这个场景的结合！

就操作符使用场景这一块而言，大概就讲解这么多，如果大家有其他的使用场景，我们可以一起交流哦。感谢大家的支持，谢谢！