RxJava

RxJava 變換操作符 map / flatmap

Map

攔截與接收被觀察者發(fā)送的事件，按照需求改變事件，再發(fā)送給觀察者「觀察者接收到的事件是改變后的事件」

Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
            }
        }).map(new Function<Integer, String>() {
            @Override
            public String apply(Integer integer) throws Exception {
                return "This is result " + integer;
            }
        }).subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.d(TAG, s); //接收的String為改變后的String
            }
        });

//Print 
 D/TAG: This is result 1 
 D/TAG: This is result 2 
 D/TAG: This is result 3

參考文章：
https://juejin.im/post/5848dd3eac502e00691385c5