Package io.servicetalk.concurrent.api

Interface ScanLifetimeMapper<T,R>

Type Parameters:

T - Type of items emitted by the Publisher this operator is applied.

R - Type of items emitted by this operator.

All Superinterfaces:

ScanMapper<T,R>

public interface ScanLifetimeMapper<T,R>
extends 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 Type	Method	Description
void	afterFinally()	Invoked after a terminal signal PublisherSource.Subscriber.onError(Throwable) or PublisherSource.Subscriber.onComplete() or Cancellable.cancel().

Methods inherited from interface io.servicetalk.concurrent.api.ScanMapper

mapOnComplete, mapOnError, mapOnNext

Method Details

afterFinally

void afterFinally()

Invoked after a terminal signal PublisherSource.Subscriber.onError(Throwable) or PublisherSource.Subscriber.onComplete() or Cancellable.cancel(). No further interaction will occur with the ScanLifetimeMapper to prevent use-after-free on internal state.