Skip to content

Latest commit

 

History

History
36 lines (18 loc) · 761 Bytes

File metadata and controls

36 lines (18 loc) · 761 Bytes

RxJava

reactive-streams

核心接口和实现

  1. Publisher

    只有一个subscribe方法,参数是Subscriber调用subscribe后Publisher会回调Subscriber的onSubscribe方法,Publisher内部会构建一个Subscription

    传递给onSubscribe

  2. Subscriber

    在onSubscribe方法内部会调用Subscriptionrequest方法,而request方法内部会调用Subscriber的onNext,onErroronComplete方法

  3. Subscription

    每一个Subscription实例对应一个Subscriber实例

上游通过subscribe方法将Subscription传给下游

rxJava

核心接口和实现

  1. Flowable

    入口,同时也是各种Flowable的基类

Flowable操作符

  1. subscribeOn

    指定Subscriber在哪个线程池上运行