Package io.servicetalk.concurrent
Interface PublisherSource.Processor<T,R>
-
- Type Parameters:
T
- The type ofPublisherSource.Subscriber
.R
- the type ofPublisherSource
.
- All Superinterfaces:
PublisherSource<R>
,PublisherSource.Subscriber<T>
- Enclosing interface:
- PublisherSource<T>
public static interface PublisherSource.Processor<T,R> extends PublisherSource<R>, PublisherSource.Subscriber<T>
APublisherSource.Processor
represents a processing stage that is both aPublisherSource
and aPublisherSource.Subscriber
and obeys the contracts of both.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.PublisherSource
PublisherSource.Processor<T,R>, PublisherSource.Subscriber<T>, PublisherSource.Subscription
-
-
Method Summary
-
Methods inherited from interface io.servicetalk.concurrent.PublisherSource
subscribe
-
Methods inherited from interface io.servicetalk.concurrent.PublisherSource.Subscriber
onComplete, onError, onNext, onSubscribe
-
-