美文网首页Android技术知识Android开发Android开发
「开源框架」RxJava(3)变换操作符「map/flatmap

「开源框架」RxJava(3)变换操作符「map/flatmap

作者: dongbingliu | 来源:发表于2018-08-08 11:15 被阅读6次
    RxJava

    RxJava 变换操作符 map / flatmap

    Map

    拦截与接收被观察者发送的事件,按照需求改变事件,再发送给观察者「观察者接收到的事件是改变后的事件」

    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

    相关文章

      网友评论

        本文标题:「开源框架」RxJava(3)变换操作符「map/flatmap

        本文链接:https://www.haomeiwen.com/subject/zhstbftx.html