RxJava 学习进行中-FlatMap

RX

RxJava很火，网络上对于它的文章非常多，这是我学习的一点笔记，也许可以帮助他人理解一点。
一开始的接触，如苍蝇叮无缝的蛋，认识久了，你会感觉很熟悉。
定义什么的，在给 Android 开发者的 RxJava 详解里面介绍得相当好。
RxJava文档中文版
大头鬼RxJava

RxJava的操作符有：

• flatMap()
• Buffer()
• filter()
• take()
• ...
• 甚至自定义操作符

1.map

对Observable发射的每一项数据应用一个函数，执行变换操作

下面这个例子是将Charecter类转换成Letter类，这样下游的操作得到的是Letter类型的信息了

        map(new Func1<Character, Letter>() {
            @Override
            public Letter call(Character character) {

                return new Letter(character);
            }
        })

2.flatMap

Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable。

这里是引用于大头鬼大神的原话。

作用：转换输入输出流，把RxJava的整个工作流程看成一条生产线，flatMap()则可以看成是该生产线上的一个加工机器，负责将输入的一类数据转换成下个步骤所需要的另一类数据（这里的类不是OO中类的概念，仅仅是说明输入和输出是不同的，如果是相同的那就没有必要加工啦）。

例子：我们现在的数据是一个String[]类型的，原本我们就直接使用这个类型的数据没有问题，后来需求改了，需要使用的是String[]中的String了。

//原本的代码
//test RxJava
    public void Method(){
        String[] strs = new String[]{"i","am","a","boy","!"};
        Observable<String[]> ob = Observable.just(strs);
        
        //消费者实际的需求是Subscriber<String>
        Subscriber<String[]> sub = new Subscriber<String[]>() {
            @Override
            public void onCompleted() {
                Log.d("log","Completed");
            }

            @Override
            public void onError(Throwable e) {
                Log.d("log","Error");
            }

            @Override
            public void onNext(String[] strings) {
                for (String s: strings
                     ) {
                    Log.d("log","next is "+s);
                }
            }
        };

        ob.subscribe(sub);
    }

Log信息如下图：

Log信息
可见循环是写在Subscriber里面的，意味着这个处理是由生产线最后的消费者（订阅者）来一个个拆开String[]箱子，拿到里面的String做处理，如果我是消费者，这种产品不符合我的要求，我还得自己去适应它，我去，买这种产品自己找虐！所以，生产线就应该满足消费者的需要。

String[] strs = new String[]{"i", "am", "a", "boy", "!"};
        Observable<String[]> ob = Observable.just(strs);
        
        //这是消费者的实际需求
        Subscriber<String> sub = new Subscriber<String>() {
            @Override
            public void onCompleted() {
                Log.d("log", "Completed");
            }

            @Override
            public void onError(Throwable e) {
                Log.d("log", "Error");
            }

            @Override
            public void onNext(String s) {

                Log.d("log", "next is " + s);

            }
        };
        
        //flatmap操作符将输入流转换成所需要的输出流
        ob.flatMap(new Func1<String[], Observable<String>>() {
            @Override
            public Observable<String> call(String[] strings) {
                return Observable.from(strings);
            }
        }).subscribe(sub);

结果是一样的

Log信息

甚至可以搞搞坏，换个性别

ob.flatMap(new Func1<String[], Observable<String>>() {
            @Override
            public Observable<String> call(String[] strings) {
                return Observable.from(strings);
            }
        }).flatMap(new Func1<String, Observable<String>>() {
            @Override
            public Observable<String> call(String s) {
                if(s.equals("boy")){
                    s= "girl";
                }
                return Observable.just(s);
            }
        }).subscribe(sub);

搞怪

不止这些，我还将两个API的调用组合到一个链式调用中了。我们可以将任意多个API调用链接起来。大家应该都应该知道同步所有的API调用，然后将所有API调用的回调结果组合成需要展示的数据是一件多么蛋疼的事情。这里我们成功的避免了callback hell（多层嵌套的回调，导致代码难以阅读维护）。现在所有的逻辑都包装成了这种简单的响应式调用。

大神特地指出了这种链式调用的优点，不得不说，链式调用是真的符合人的思维模式。