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
按约定处理订阅者和生产者流程
网友评论