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()
.boolean
Determine 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:
true
to propagateonNext()
,false
will only propagateterminal()
.
-
terminal
The terminal event to propagate.- Returns:
null
meansPublisherSource.Subscriber.onComplete()
- non-
null
will propagate asPublisherSource.Subscriber.onError(Throwable)
-