上QQ阅读APP看书,第一时间看更新
Processor rules
Processor is described with the following interface definition:
public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
}
It has just two rules. The first rule talks about the contract that must be followed by both Subscriber and Publisher , while the second rule is intended to handle the error situation, either recover or propagate to Subscriber.