StreamUtils.ScheduleSupport

Enclosing class:: StreamUtils

public static interface StreamUtils.ScheduleSupport

Method Summary

Modifier and Type

Method

Description

void

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

org.apache.pekko.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 Details
- runInContext
  
  void runInContext(scala.Function0<scala.runtime.BoxedUnit> block)
- scheduleOnce
  
  org.apache.pekko.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)