Package io.servicetalk.concurrent.api

Interface ScanWithLifetimeMapper<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:

ScanWithMapper<T,R>

@Deprecated
public interface ScanWithLifetimeMapper<T,R>
extends ScanWithMapper<T,R>

Deprecated.

Use ScanLifetimeMapper.

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 Type	Method	Description
void	afterFinally()	Deprecated. Invoked after a terminal signal PublisherSource.Subscriber.onError(Throwable) or PublisherSource.Subscriber.onComplete() or Cancellable.cancel().

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

mapOnComplete, mapOnError, mapOnNext, mapTerminal

Method Details

afterFinally

void afterFinally()

Deprecated.

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