Package org.apache.pekko.stream.scaladsl

Interface DelayStrategy<T>

public interface DelayStrategy<T>

Allows to manage delay. Can be stateful to compute delay for any sequence of elements, as instances are not shared among running streams and all elements go through nextDelay(), updating state and returning delay for that element.

Method Summary

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

Method Details

nextDelay

scala.concurrent.duration.FiniteDuration nextDelay(T elem)

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