io.servicetalk.concurrent

Interface PublisherSource.Processor<T,R>

Type Parameters:

T - The type of PublisherSource.Subscriber.

R - the type of PublisherSource.

All Superinterfaces:

PublisherSource<R>, PublisherSource.Subscriber<T>

Enclosing interface:

PublisherSource<T>

public static interface PublisherSource.Processor<T,R>
extends PublisherSource<R>, PublisherSource.Subscriber<T>

A PublisherSource.Processor represents a processing stage that is both a PublisherSource and a PublisherSource.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