RxJava 的源码解析 (五) RxJava1 Lift操作符

小灰灰 2022-05-24 00:48 226阅读 0赞

## lift 操作符 ##

> 我们这里先抛出概念

*  接口原OnSubscribe和当前的Operator
 *  创建一个新的OnSubscriber并返回新的Observable
 *  用新的 Subscriber 包裹旧的 Subscriber
 *  在新的 Subscriber 力做完变换后再传给旧的Subscriber

## 小案例 ##

Subscription subscription = Observable.create(new Observable.OnSubscribe<String>() { 
        @Override
        public void call(Subscriber<? super String> subscriber) { 
            if (!subscriber.isUnsubscribed()) { 
                subscriber.onNext("1");
                subscriber.onNext("2");
                subscriber.onCompleted();
            }
        }
    }).map(new Func1<String, Integer>() { 
        @Override
        public Integer call(String s) { 
            return Integer.valueOf(s);
        }
    }).subscribe(new Observer<Integer>() { 
    
        @Override
        public void onCompleted() { 
            System.out.println("onCompleted");
        }
    
        @Override
        public void onError(Throwable e) { 
            e.printStackTrace();
            System.out.println("onError");
    
        }
    
        @Override
        public void onNext(Integer s) { 
            System.out.println("onNext：" + s);
        }
    });

## 执行流程分析 ##

> 源码自己分析，我们这里主要罗列下逻辑图

https://www.processon.com/view/link/5afcdd73e4b096c6eeb4b443

发表评论取消回复

表情：

评论列表（有 0 条评论，226人围观）

还没有评论，来说两句吧...

相关阅读

相关 RxJava2 / RxJava2操作符scan

RxJava2 / RxJava2操作符scan scan操作符将Observable的结果在BiFunction扫描一遍后交给Observer使用，scan最大的功用

亦凉/ 2024年02月17日 22:07/ 0 赞/ 55 阅读

相关 RxJava基本流程和lift源码分析

基本结构我们先来看一段最基本的代码，分析这段代码在RxJava中是如何实现的。 <code class="language-Java hljs java ha

冷不防/ 2022年09月26日 03:03/ 0 赞/ 186 阅读

相关 RxJava 之操作符

什么是RxJava RxJava 就是异步 RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。一个响应式的编程框架什么是RxJava

心已赠人/ 2022年09月24日 10:20/ 0 赞/ 213 阅读

相关 Rxjava 的源码解析 (二) RxJava1 基本元素分析

文章目录介绍讲解使用的库简单使用五大主要元素 Observable

快来打我*/ 2022年05月25日 14:16/ 0 赞/ 216 阅读

相关 RxJava 的源码解析 (六) RxJava1 Scheduler调度者概念

文章目录先了解下概念小案例 1.0 的 Scheduler subscribeOn 调度图

╰半夏微凉°/ 2022年05月24日 01:23/ 0 赞/ 168 阅读

相关 RxJava 的源码解析 (五) RxJava1 Lift操作符

lift 操作符 > 我们这里先抛出概念接口原OnSubscribe和当前的Operator 创建一个新的OnSubscriber并返回新的Observa

小灰灰/ 2022年05月24日 00:48/ 0 赞/ 227 阅读

相关 RxJava操作符大全

方便使用时查找版权声明：本文为转载的博主原创文章。 https://blog.csdn.net/maplejaw\_/article/details/52396175

素颜马尾好姑娘i/ 2022年04月03日 02:56/ 0 赞/ 196 阅读

相关 RxJava 转换操作符详解及lift 源码解析

RxJava 提供了对事件序列进行变换的支持，这是它的核心功能之一，也是大多数人说『RxJava 真是太好用了』的最大原因。所谓变换，就是将事件序列中的对象或整个序列进行加工处

缺乏、安全感/ 2022年02月24日 18:54/ 0 赞/ 246 阅读

相关 RxJava 源码解析篇

说实话rxjava 的确是我见过最绕，最强大，最复杂的类库之一，对于一般的开发者基本上都是望文却步！比如在[netflix hystrix][]的AbstractCommand

谁践踏了优雅/ 2022年02月24日 14:40/ 0 赞/ 262 阅读

相关 RxJava源码阅读,map操作符(二)

1.基本写法 Observable.just("https://user-gold-cdn.xitu.io/2019/5/17/16ac4f7f486ca77a?

悠悠/ 2022年01月19日 04:25/ 0 赞/ 206 阅读