Advertisement

RxJava 2.x源码分析(三)及其变换操作符map及其flatMap

阅读量:

RxJava提供的操作符种类繁多,在这其中最常见的就是变换操作符。这些操作中最关键的就是Map与FlatMap两种核心功能。本文将详细阐述它们的工作机制以及具体实现方式。在我们之前的文章《RxJava 2.x 源码分析(二) 线程切换原理》中已经对框架的整体运行逻辑进行了深入解析。了解这些知识对咱们后续代码的理解会产生很大帮助作用。如果你还想深入了解这一机制,请参考上一篇详细解析的文章

一:map的实现原理

老规矩,先上一个例子:

复制代码
  Observable.create(new ObservableOnSubscribe<Integer>() {

    
         @Override
    
         public void subscribe(@NonNull ObservableEmitter<Integer> e) throws Exception {
    
             e.onNext(1);
    
             e.onNext(2);
    
             e.onNext(3);
    
             e.onNext(4);
    
         }
    
     }).map(new Function<Integer, String>() {

全部评论 (0)

还没有任何评论哟~