RXjava 简介

2017-07-20 本文已影响23人 3Q竹林

Rxjava操作符简介:

just: 可传入一到九个参数，它们会按照传入的顺序来发射它们。它也可以接受列表或数组，就像from()方法，但它不会迭代列表发射每个值,它只会发射整个列表。

creat:创建Observable并规划"Observer"中方法的如何执行及参数的设置，例子如下；

zip：两个请求并发的发出，并且等待两个结果都返回之后再做处理；

lift:针对事件序列的处理和再发送,可用compose替换使用；

range:Observable.range(10,3)第一个是起始点，第二个是我们想发射数字的个数。

repeat：对一个Observable重复发射数据；

distinct和distinctUntilChanged：去重，规定的值既只处理一次；

First和last：从可观测源序列中创建只发射第一个或者最后一个序列，相似的变量有：firstOrDefault()和lastOrDefault()；

Skip和SkipLast：创建一个不发射前N个元素而是发射它后面的那些数据的序列。

elementAt：函数仅从一个序列中发射第n个元素然后就完成了。

Timeout：超时却未发射数据，则会调用onError方法；

debounce:能过滤掉由Observable发射的速率过快的数据；

sample：它将在一个指定的时间间隔里由Observable发射最近一次的数值，类似于interval；

interval:创建轮询程序Observable.interval(1,TimeUnit.SECONDS)一个指定两次发射时间间隔，另一个是时间单位,与range联用可实现跑秒功能，与take能实现倒计时功能

defer：推迟Observable的创建，直到观察者订阅时。

timer: Observable.timer(3,3,TimeUnit.SECONDS)：延迟发送，参数：首次延迟时间,延迟周期,时间单位

buffer：将源Observable变换一个新的Observable，新的Observable每次发射一组列表值而不是一个一个发射即缓冲发送。

window：函数和buffer()很像，但是它发射的时Observable而不是列表。

take:限定Observable只发射前几项take(11);

filter：筛选器，筛选出合格的Observable；

from : 从众多数据中逐一取数据进行操作，或理解为将传入的数组或 Iterable 拆分成具体对象后，依次发送出来；

map:将请求的结果转化成任意对象(包括Observeble对象)参数，并作为下一个操作的参数；

cast:它是map()操作符的特殊版本，它将源Observable中的每一项数据都转换为新的不同的Class类型。

flatMap:将请求的结果转化成Observeble对象参数，并作为下一个操作的参数（多用于链式请求/操作），（注意其不能维持元素之前的输出顺序,可用ConcatMap替换）

concatMap:与flatMap使用几乎相同，不同的是concatMap能有序的发射数据，解决了flatmap交错问题；

switchMap：每当源Observable发射一个新的数据项（Observable）时，它将取消订阅并停止监视之前那个数据项产生的Observable，并开始监视当前发射的这个。

flatMapIterable：其和flatMap类似，仅有的本质不同是它将源数据两两结成对并生成Iterable；？

scan：可看做是一个累加器函数，它会将上次发射的"结果"，作为下个数据应用合格函数时的"第一个参数"使用。

concat: 其与concatMap一样，也是有序的，发射数据不会出现交叉，并且concat操作符是接收若干个Observables，可用于实现缓存逻辑内存缓存、本地缓存、网络中获取（结合first()使用），也可使用switchIfEmpty；

groupBy:将原Observable数据按照key拆分成一些小的Observable，然后将这些小Observable分别发射其所包含的的数据；

compose：Observable.compose() 和 Transformer一起使用，作用是替换和复用"Observable"一些操作符，用法如下；

练习：

Observable<AppInfo> fullOfDuplicates = Observable.from(apps)
    .take(3) //只执行前三项
    .repeat(3); //每项再重复执行3次，共执行9次

操作符详解网址：http://www.devtf.cn/?p=1225
RxJava全解网址：http://www.jianshu.com/p/b04202d06427

注意上边的所有方法的返回值都是Observable，这样才能实现链式编程，而map和flatMap改变的转化的对象，最后都是对应下一个接收方法中的参数；

Observable.create用法

Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        //指定了新创建的Observable在被订阅后，会调用三次Subscriber的onNext方法，并对参数进行了修改；
        subscriber.onNext("Hello");  
        subscriber.onNext("Hi");
        subscriber.onNext("Aloha");
        subscriber.onCompleted();
    }
});

Observable.compose用法（需与Transformer联合使用）

//与Observable.compose在同一个类中使用，已达到简写操作符的目的
<T> Transformer<T, T> applySchedulers() {  
  return new Transformer<T, T>() {
    @Override
    public Observable<T> call(Observable<T> observable) {
      return observable.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread());
    }
  };
}

Observable.from(someSource)  
    .map(data -> manipulate(data))
    .compose(applySchedulers())
    .subscribe(data -> doSomething(data));

详解网址：http://blog.csdn.net/u013378580/article/details/51607677

buffer用法

//buffer中的skip表示：执行完一次后，向后跳过（skipNum - countNum）个数值再缓冲发送;
// 执行逻辑：先将最先缓冲的3个数据一起发送，然后跳到skip设定的位置（注意：此处7-3=4）,既每次发送完数据后，跳过（skip - count）个值，再发送数据；
ArrayList<String> list = new ArrayList<>();
 for (int i = 0;i < 22;i++) {
   list.add("D" + i);
  }
Observable.from(list).buffer(3,7).subscribeOn(AndroidSchedulers.mainThread())
 .subscribe(new Action1<List<String>>() {
   @Override public void call(List<String> strings) {
     LogUtil.showLog("tagg",strings.toString());
   }
 });

compose()和flatMap()在复用"Observable"一些操作符功能上的区别:

compose()是唯一一个能从流中获取原生Observable 的方法，因此，影响整个流的操作符（像subscribeOn()和observeOn()）需要使用compose()，相对的，如果你在flatMap()中使用subscribeOn()/observeOn()，它只影响你创建的flatMap()中的Observable,而不是整个流。
当你创建一个Observable流并且内联了一堆操作符以后，compose()会立即执行，flatMap()则是在onNext()被调用以后才会执行，换句话说，flatMap()转换的是每个项目，而compose()转换的是整个流。flatMap()一定是低效率的，因为他每次调用onNext()之后都需要创建一个新的Observable，compose()是操作在整个流上的。

总之，compose()是高等级的抽象，他操作的是整个流，而不是单一发射出的项目，如果你想用可重用的代码替换一些操作符，可以利用compose()和flatMap()，但不是唯一的办法。

RXjava 简介

Rxjava操作符简介:

练习：

猜你喜欢

热点阅读