1.Map操作符
作用：將被觀察者發(fā)送的事件轉(zhuǎn)換為任意類型的事件
例子：數(shù)據(jù)類型的轉(zhuǎn)換

/**
     * map 操作符
     * 事件轉(zhuǎn)換
     * 將被觀察者發(fā)送的事件轉(zhuǎn)換為任意的類型事件。
     * 例子：數(shù)據(jù)類型轉(zhuǎn)換
     */
    private void map() {
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(111);
            }
            //使用map操作符進(jìn)行事件轉(zhuǎn)換
        }).map(new Function<Integer, String>() {
            @Override
            public String apply(Integer integer) throws Exception {
                return String.valueOf(integer) + "你好";
            }
            //被觀察者訂閱事件
        }).subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.e(TAG, "轉(zhuǎn)換結(jié)果： " + s);
            }
        });
    }

輸出結(jié)果:

image.png

2.FlatMap操作符
作用：將被觀察者發(fā)送的多個(gè)事件進(jìn)行拆分，分別轉(zhuǎn)換為不同的事件
，然后合并成新的事件
例子：將每個(gè)Integer數(shù)據(jù)分別轉(zhuǎn)換成一個(gè)List，然后再迭代

/**
     *FlatMap 操作符
     * 將被觀察者的事件順序拆分
     *
     * 單獨(dú)轉(zhuǎn)換
     *  在合并成新的事件
     *
     */
    private void flatMap(){
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
                Log.e(TAG, "----- " );

            }
        }).flatMap(new Function<Integer, ObservableSource<String>>() {
            @Override
            public ObservableSource<String> apply(Integer integer) throws Exception {
                List<String> list = new ArrayList<>();
                //分別對(duì)被觀察者的事件進(jìn)行加工轉(zhuǎn)換i
                for (int i = 0; i <2 ; i++) {
                    list.add("我是事件"+integer+"拆分后的子事件為"+i);
                }
                Log.e(TAG, "---------");
                //拆分后合并
                //
                return Observable.fromIterable(list);
            }
        }).subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.e(TAG, "accept: "+s );
            }
        });

    }

輸出結(jié)果:

image.png

3.ConcatMap操作符
和FlatMap操作符原理一樣，區(qū)別在于 FlatMap把事件拆分再合并的時(shí)候，順序可能和被觀察者發(fā)送的事件順序不一樣，而ConcatMap操作符處理后的事件順序和被觀察者發(fā)送事件的順序是一樣的。

 /**
     * 類似FlatMap（）操作符
     * 但是新事件循序還是和觀察者的順序一樣
     */
    private void concatMap(){
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
                e.onNext(4);
                e.onNext(5);
                e.onNext(6);
                Log.e(TAG, "----- " );
            }
        }).concatMap(new Function<Integer, ObservableSource<String>>() {
            @Override
            public ObservableSource<String> apply(Integer integer) throws Exception {
                List<String> list = new ArrayList<>();
                for (int i = 0; i <2 ; i++) {
                    list.add("我是事件"+integer+"拆分后的子事件為"+i);
                }
                Log.e(TAG, "----- " );
                return Observable.fromIterable(list);
            }
        }).subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.e(TAG, "accept: "+s );
            }
        });
    }

輸出結(jié)果：

image.png

4.Buffer操作符
把被觀察者的事件進(jìn)行緩存，然后每次從緩存中拿出一定數(shù)量事件發(fā)送給觀察者。

  /**
     * buffer 操作符
     * 定期從 被觀察者（Obervable）需要發(fā)送的事件中
     * 獲取一定數(shù)量的事件 & 放到緩存區(qū)中，最終發(fā)送
     * 緩存被觀察者的發(fā)送事件
     *
     */
    private void buffer(){
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
                e.onNext(4);
            }
        }).buffer(2,1)//參數(shù)1：每次發(fā)送給觀察者事件的數(shù)量。參數(shù)2：每次從緩存中取出事件的數(shù)量
        .subscribe(new Consumer<List<Integer>>() {
            @Override
            public void accept(List<Integer> i) throws Exception {
                for (int j = 0; j <i.size() ; j++) {
                    Log.e(TAG, "accept: "+i.get(j) );
                }
            }
        });
    }

輸出結(jié)果

image.png