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()，但不是唯一的办法。
.
网友评论