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