Top Description Methods
org.reactivestreams

public Interface Processor<T, R>

extends Subscriber<T>, Publisher<R>
Known Direct Implementers
org.reactivestreams.FlowAdapters.ReactiveToFlowProcessor
Type Parameters
<T>
the type of element signaled to the Subscriber
<R>
the type of element signaled by the Publisher
A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.

Method Summary

Inherited from org.reactivestreams.Publisher:
subscribe
Inherited from org.reactivestreams.Subscriber:
onCompleteonErroronNextonSubscribe