Interface Processor<T,R>

Type Parameters:
T - the type of element signaled to the Subscriber
R - the type of element signaled by the Publisher
All Superinterfaces:
Publisher<R>, Subscriber<T>
All Known Implementing Classes:
FlowAdapters.ReactiveToFlowProcessor
public interface Processor<T,R> extends Subscriber<T>, Publisher<R>
A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.