RxJava学习笔记 -- 转换Observables --

注：本文摘自《RxJava Essentials》翻译中文版电子书

*map家族

Map

map函数接收一个指定的Func对象然后将它应用到每一个由Observable发射的值上。例子：

private void loadList(List<AppInfo> apps) {
    Observable.from(apps)
        .map(new Func1<AppInfo,AppInfo>(){
            @Override
            public Appinfo call(AppInfo appInfo){
                String currentName = appInfo.getName();
                String lowerCaseName = currentName.toLowerCase();
                appInfo.setName(lowerCaseName);
                return appInfo;
            }
        })
        .subscribe(...);
}

上面例子实现了能够显示同样的列表，但是又要所有的名字都小写。

FlatMap

如果有这样一个需求：我们有一个这样的Observable，它发射一个数据序列，这些数据本身也可以发射Observable，这时候可以使用FlatMap。

当我们在处理可能有大量的Observables时，重要是记住任何一个Observables发生错误的情况，flatMap()将会触发它自己的onError()函数并放弃整个链。

重要的一点提示是关于合并部分：它允许交叉。如下图

这意味着flatMap()不能够保证在最终生成的Observable中源Observables确切的发射顺序。

ConcatMap

concatMap()函数解决了flatMap()的交叉问题，提供了一种能够把发射的值连续在一起的铺平函数，而不是合并它们。

FlatMapIterable

flatMapInterable()和flatMap()很像。仅有的本质不同是它将源数据两两结成对并生成Iterable，而不是原始数据项和生成的Observables。

SwitchMap

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

Scan

scan()函数可以看做是一个累积函数。scan()函数对原始Observable发射的每一项数据都应用一个函数，计算出函数的结果值，并将该值填充回可观测序列，等待和下一次发射的数据一起使用。
一个累加器例子：

Observable.just(1,2,3,4,5)
        .scan((sum,item) -> sum + item)
        .subscribe(...);

输出结果是：1，3，6，10，15

比较每个安装应用的名字从而创建一个名字长度递增的列表：

private void loadList(List<AppInfo> apps) {
    Observable.from(apps)
            .scan((appInfo,appInfo2) -> {
                if(appInfo.getName().length > appInfo2.getName().length()){
                    return appInfo;
                } else {
                    return appInfo2;
                }
            })
            .distinct()
            .subscribe(...);
}

GroupBy

groupBy() 是分组元素，依然是那个例子，我们想按照最近更新日期来排序我们的App时该怎么办？

Observable<GroupedObservable<String,AppInfo>> groupedItems = Observable.from(apps)
    .groupBy(new Func1<AppInfo,String>(){
        @Override
        public String call(AppInfo appInfo){
            SimpleDateFormat formatter = new SimpleDateFormat("MM/yyyy");
            return formatter.format(new Date(appInfo.getLastUpdateTime()));
        }
    });

Observable.concat(groupedItems)
    .subscribe(...);

GroupedObservable是一个特殊的Observable，它源自一个分组的key。在这个例子中，key就是String，代表的意思是Month/Year格式化的最近更新日期。最后，我们将创建一个新的Observable将所有的联系起来。

Buffer

buffer()函数将源Observable变换一个新的Observable，这个新的Observable每次发射一组列表值而不是一个一个发射。

上图中展示了buffer()如何将count作为一个参数来指定有多少数据项被包在发射的列表中。实际上，buffer()函数有几种变体。其中有一个是允许你指定一个skip值：此后每skip项数据，然后又用count项数据填充缓冲区。如下图所示：

buffer()带一个timespan的参数，会创建一个每隔timespan时间段就会发射一个列表的Observable。

Window

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

Cast

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