Package io.servicetalk.concurrent.api
Interface ScanWithLifetimeMapper<T,R>
-
- Type Parameters:
T- Type of items emitted by thePublisherthis 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 voidafterFinally()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 theScanWithLifetimeMapperto prevent use-after-free on internal state.
-
-