Package org.apache.pekko.stream.javadsl

Interface DelayStrategy<T>

public interface DelayStrategy<T>

Allows to manage delay and can be stateful to compute delay for any sequence of elements, all elements go through nextDelay() updating state and returning delay for each element

Method Summary

Modifier and Type	Method	Description
Duration	nextDelay(T elem)	Returns delay for ongoing element, Duration.Zero means passing without delay

Method Details

nextDelay

Duration nextDelay(T elem)

Returns delay for ongoing element, Duration.Zero means passing without delay