Package io.servicetalk.concurrent
Interface SingleSource.Processor<T,R>
- Type Parameters:
T
- The type ofSingleSource.Subscriber
.R
- the type ofSingleSource
.
- 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