Package io.servicetalk.concurrent.api
Interface ScanMapper.MappedTerminal<R>
- Type Parameters:
R- The mapped result type.
- Enclosing interface:
- ScanMapper<T,
R>
public static interface ScanMapper.MappedTerminal<R>
Result of a mapping operation of a terminal signal.
-
Method Summary
Modifier and TypeMethodDescriptiononNext()Get the signal to be delivered toPublisherSource.Subscriber.onNext(Object)ifonNextValid().booleanDetermine ifonNext()is valid and should be propagated downstream.terminal()The terminal event to propagate.
-
Method Details
-
onNext
Get the signal to be delivered toPublisherSource.Subscriber.onNext(Object)ifonNextValid().- Returns:
- the signal to be delivered to
PublisherSource.Subscriber.onNext(Object)ifonNextValid().
-
onNextValid
boolean onNextValid()Determine ifonNext()is valid and should be propagated downstream.- Returns:
trueto propagateonNext(),falsewill only propagateterminal().
-
terminal
The terminal event to propagate.- Returns:
nullmeansPublisherSource.Subscriber.onComplete()- non-
nullwill propagate asPublisherSource.Subscriber.onError(Throwable)
-