风行云通 策马长歌逍遥游

RxJava日常，周六懒癌症发作了，啊，控制不住了，就让我躺在这沙发上一动不动吧。

FlatMap

打开后场盖牌，启动强势转换装置，以上。
这玩意可以把上游的冰霜魔法强势转换为火焰魔法。

Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
            }
        }).flatMap(new Function<Integer, ObservableSource<String>>() {
            @Override
            public ObservableSource<String> apply(Integer integer) throws Exception {
                final List<String> list = new ArrayList<>();
                for (int i = 0; i < 3; i++) {
                    list.add("I am value " + integer);
                }
                return Observable.fromIterable(list).delay(10,TimeUnit.MILLISECONDS);
            }
        }).subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.d(TAG, s);
            }
        });

就是这么用，就是这么的强势。

兄弟concatMap

• 用法相同
• 区别，上面那个家伙是无序的，而这家伙是严格按顺序来的。

bserveOn(xxxxxxx)

• 线程切换装置，用了它主线程子线程来回切换，畅游UI。
• 用法，不管想用的时候就用就好了。
• 参数，上一章说的都能用。

---

Over，方圆几里

薛之谦