org.apache.pekko.http.impl.util

Interface StreamUtils.ScheduleSupport

Enclosing class:

StreamUtils

public static interface StreamUtils.ScheduleSupport

Method Summary

Modifier and Type	Method and 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 Detail

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)