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

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

    • Method Detail

      • nextDelay

        java.time.Duration nextDelay​(T elem)
        Returns delay for ongoing element, Duration.Zero means passing without delay