Package io.servicetalk.concurrent.api
Interface ScanWithLifetimeMapper<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:
ScanWithMapper<T,
R>
Deprecated.
Provides the ability to transform (aka map) signals emitted via
the
Publisher.scanWithLifetime(Supplier)
operator, as well as the ability to cleanup state
via afterFinally()
.-
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated.Invoked after a terminal signalPublisherSource.Subscriber.onError(Throwable)
orPublisherSource.Subscriber.onComplete()
orCancellable.cancel()
.Methods inherited from interface io.servicetalk.concurrent.api.ScanWithMapper
mapOnComplete, mapOnError, mapOnNext, mapTerminal
-
Method Details
-
afterFinally
void afterFinally()Deprecated.Invoked after a terminal signalPublisherSource.Subscriber.onError(Throwable)
orPublisherSource.Subscriber.onComplete()
orCancellable.cancel()
. No further interaction will occur with theScanWithLifetimeMapper
to prevent use-after-free on internal state.
-
ScanLifetimeMapper
.