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>
public interface ScanWithLifetimeMapper<T,R> extends ScanWithMapper<T,R>
Provides the ability to transform (aka map) signals emitted via thePublisher.scanWithLifetime(Supplier)
operator, as well as the ability to cleanup state viaafterFinally()
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
afterFinally()
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 Detail
-
afterFinally
void afterFinally()
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.
-
-