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)