Package akka.http.impl.util

Interface StreamUtils.ScheduleSupport

  • Enclosing class:
    StreamUtils
    public static interface StreamUtils.ScheduleSupport

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void runInContext​(scala.Function0<scala.runtime.BoxedUnit> block)  
      akka.actor.Cancellable scheduleOnce​(scala.concurrent.duration.FiniteDuration delay, scala.Function0<scala.runtime.BoxedUnit> block)
      Schedule a block to be run once after the given duration in the context of this graph stage.

    • Method Detail

      • runInContext

        void runInContext​(scala.Function0<scala.runtime.BoxedUnit> block)

      • scheduleOnce

        akka.actor.Cancellable scheduleOnce​(scala.concurrent.duration.FiniteDuration delay,
                                    scala.Function0<scala.runtime.BoxedUnit> block)
        Schedule a block to be run once after the given duration in the context of this graph stage.
        Parameters:
        delay - (undocumented)
        block - (undocumented)
        Returns:
        (undocumented)