Rxjava源码解析01-明确概念

电玩女神 2023-10-17 15:23 146阅读 0赞

### RxJava源码解析01-明确概念 ###

在进行RxJava源码解析前，我们需要先明确几个概念。

#### Observer(观察者) ####

拥有onNext、onError、onCompleted这三个方法

1.  onNext: 表示一个普通的事件
2.  onError: 表示事件队列异常。如果事件处理过程中出现异常，会调用onError，同时事件队列终止，不会再有事件发出。
3.  onCompleted: 表示事件队列结束。一串的事件，会组成一个事件队列，当事件队列执行结束之后，最后会调用onCompleted。(如果中途出现异常，调用onError，那么onCompleted不会再被调用)

#### Subscriber(观察者) ####

在Observable的基础之上，增加了onStart方法，这个方法在事件还未被发出之前调用，可以用于做一些准备工作。例如数据的清零或重置。这是个可选方法，默认情况下onStart的实现为空。  
同时，实现了Subscription接口，具有`unsubscribe`和`isUnsubscribed`方法  
**事实上，所有的Observer都会被当做Subscriber来处理。**

public abstract class Subscriber<T> implements Observer<T>, Subscription{
    
    }

#### Observable(被观察者) ####

被观察者发生了某些变化，会通知给以注册的观察者。每个Observable内部都有一个OnSubscriber，OnSubscriber拥有一个方法call()，根据不同的OnSubscriber，会以不同的方式调用Subscriber的onNext、onCompleted等方法来通知观察者。

public class Observable<T> {
        final OnSubscriber<T> onObservable;
    
        public Observable(OnSubscriber<T> onObservable) {
            this.onObservable = onObservable;
        }
    
        public static <T> Observable<T> create(OnSubscriber<T> onSubscriber) {
            return new Observable<>(onSubscriber);
        }
    
        //...
    }

#### Subscription(接口) ####

Observable调用subscribe方法的对象，这是个接口，有`unsubscribe`和`isUnsubscribed`方法。  
同时，Subscriber对象是实现了这个接口的。

public interface Subscription {
    
        void unsubscribe();
    
        boolean isUnsubscribed();
    }

#### OnSubscribe(接口) ####

OnSubscribe是一个接口，继承自Action1接口，当`Observable.subscribe()`的时候，OnSubscribe的call方法将被调用。  
即把他视为一个用来调用Subscriber的Action1即可。

public interface OnSubscribe<T> extends Action1<Subscriber<? super T>> {
        // cover for generics insanity
    }  
    
    public interface Action1<T> extends Action {
        void call(T t);
    }

#### Func1，Action1 ####

Func1和Action1非常相似，都继承自Action接口，用于包装含有一个参数的方法。  
Func1和Action1的区别在于，Func1包装的是有返回值的方法。另外，和ActionX一样，FuncX也有多个，用于不同参数个数的方法。FuncX和ActionX的区别在于FuncX包装的是有返回值的方法。

public interface Func1<T, R> extends Function {
        R call(T t);
    }
    
    public interface Action1<T> extends Action {
        void call(T t);
    }
    
    public interface Action extends Function {
    
    }
    
    public interface Function {
    
    }

发表评论取消回复

表情：

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

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

相关阅读

相关 RxJava源码解析05-线程切换

RxJava源码解析05-线程切换这篇文章我们来分析一下RxJava线程的切换。 Observable.just("123") .subscr

爱被打了一巴掌/ 2023年10月17日 15:46/ 0 赞/ 74 阅读

相关 RxJava源码解析04-变换过程(flatmap)

flatmap public final <R> Observable<R> flatMap(Func1<? super T, ? extends Observa

太过爱你忘了你带给我的痛/ 2023年10月17日 15:46/ 0 赞/ 74 阅读

相关 RxJava源码解析02-订阅过程

RxJava源码解析-订阅过程以最简单的调用过程为例 Observable.create(new Observable.OnSubscribe<String>

柔情只为你懂/ 2023年10月17日 15:28/ 0 赞/ 146 阅读

相关 Rxjava源码解析01-明确概念

RxJava源码解析01-明确概念在进行RxJava源码解析前，我们需要先明确几个概念。 Observer(观察者) 拥有onNext、onError、onCo

电玩女神/ 2023年10月17日 15:23/ 0 赞/ 147 阅读

相关 Rxjava源码解析之监听回调

Rxjava源码解析之监听回调 -------------------- 前言 > 该篇分析Rxjava接口回调流程的逻辑，为了方便理解，用最简单的实例分析。

约定不等于承诺〃/ 2022年05月27日 09:22/ 0 赞/ 230 阅读

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

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

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

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

文章目录 2.0 Scheduler Android 中的 Scheduler 流程图 2.0 Sche

约定不等于承诺〃/ 2022年05月24日 03:15/ 0 赞/ 177 阅读

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

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

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

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

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

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

相关 RxJava 源码解析篇

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

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