Package akka.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

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

    • Method Detail

      • nextDelay

        scala.concurrent.duration.FiniteDuration nextDelay​(T elem)
        Returns delay for ongoing element, Duration.Zero means passing without delay