Package io.servicetalk.concurrent.api

Interface ReplayAccumulator<T>

Type Parameters:

T - The type of data to accumulate.

public interface ReplayAccumulator<T>

Accumulates signals for the Publisher replay operator.

Method Summary

Modifier and Type	Method	Description
void	accumulate(T t)	Called on each PublisherSource.Subscriber.onNext(Object) and intended to accumulate the signal so that new PublisherSource.Subscribers will see this value via deliverAccumulation(Consumer).
default void	cancelAccumulation()	Called if the accumulation can be cancelled and any asynchronous resources can be cleaned up (e.g.
void	deliverAccumulation(Consumer<T> consumer)	Called to deliver the signals from accumulate(Object) to new consumer.

Method Details

accumulate

void accumulate(@Nullable
 T t)

Called on each PublisherSource.Subscriber.onNext(Object) and intended to accumulate the signal so that new PublisherSource.Subscribers will see this value via deliverAccumulation(Consumer).

This method won't be called concurrently, but should return quickly to minimize performance impacts.

Parameters:

t - An PublisherSource.Subscriber.onNext(Object) to accumulate.

deliverAccumulation

void deliverAccumulation(Consumer<T> consumer)

Called to deliver the signals from accumulate(Object) to new consumer.

Parameters:

consumer - The consumer of the signals previously aggregated via accumulate(Object).

cancelAccumulation

default void cancelAccumulation()

Called if the accumulation can be cancelled and any asynchronous resources can be cleaned up (e.g. timers).