Package io.servicetalk.concurrent

Interface SingleSource.Processor<T,R>

Type Parameters:

T - The type of SingleSource.Subscriber.

R - the type of SingleSource.

All Superinterfaces:

SingleSource<R>, SingleSource.Subscriber<T>

Enclosing interface:

SingleSource<T>

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

A SingleSource.Processor represents a processing stage that is both a SingleSource and a SingleSource.Subscriber and obeys the contracts of both.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.SingleSource

SingleSource.Processor<T,R>, SingleSource.Subscriber<T>

Method Summary

Methods inherited from interface io.servicetalk.concurrent.SingleSource

subscribe

Methods inherited from interface io.servicetalk.concurrent.SingleSource.Subscriber

onError, onSubscribe, onSuccess