- Type Parameters:
T- the type of element signaled to the
R- the type of element signaled by the
- All Superinterfaces:
public interface Processor<T,R> extends Subscriber<T>, Publisher<R>A Processor represents a processing stage—which is both a
Publisherand obeys the contracts of both.
Methods inherited from interface org.reactivestreams.Subscriber
onComplete, onError, onNext, onSubscribe