-
Publisher
只有一个
subscribe方法,参数是Subscriber调用subscribe后Publisher会回调Subscriber的onSubscribe方法,Publisher内部会构建一个Subscription传递给onSubscribe
-
Subscriber
在onSubscribe方法内部会调用
Subscription的request方法,而request方法内部会调用Subscriber的onNext,onError和onComplete方法 -
Subscription
每一个Subscription实例对应一个Subscriber实例
上游通过subscribe方法将Subscription传给下游
-
Flowable
入口,同时也是各种Flowable的基类
-
subscribeOn
指定Subscriber在哪个线程池上运行