Package io.servicetalk.concurrent.api
Interface ScanLifetimeMapper<T,R>
- Type Parameters:
T
- Type of items emitted by thePublisher
this operator is applied.R
- Type of items emitted by this operator.
- All Superinterfaces:
ScanMapper<T,
R>
Provides the ability to transform (aka map) signals emitted via
the
Publisher.scanWithLifetimeMapper(Supplier)
operator, as well as the ability to cleanup state
via afterFinally()
.-
Nested Class Summary
Nested classes/interfaces inherited from interface io.servicetalk.concurrent.api.ScanMapper
ScanMapper.MappedTerminal<R>
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Invoked after a terminal signalPublisherSource.Subscriber.onError(Throwable)
orPublisherSource.Subscriber.onComplete()
orCancellable.cancel()
.Methods inherited from interface io.servicetalk.concurrent.api.ScanMapper
mapOnComplete, mapOnError, mapOnNext
-
Method Details
-
afterFinally
void afterFinally()Invoked after a terminal signalPublisherSource.Subscriber.onError(Throwable)
orPublisherSource.Subscriber.onComplete()
orCancellable.cancel()
. No further interaction will occur with theScanLifetimeMapper
to prevent use-after-free on internal state.
-