rxjava2概念

Publisher 消息生产者，发送消息给 Subscriber

Subscriber 消息订阅者，订阅并消费消息

public void onSubscribe(Subscription s)

public void onNext(T t)

public void onError(Throwable t)

public void onComplete()

Subscription

一对一表示订阅者和生产者订阅关系

一个subscriber对应一个Subscription, 可以控制接收数据和取消订阅

Processor

interface Processor<T, R> extends Subscriber, Publisher

按约定处理订阅者和生产者流程