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)
还没有任何评论哟~
