org.reactivestreams

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>

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.

Method Summary

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface org.reactivestreams.Publisher

subscribe