object DelayStrategy
- Source
- DelayStrategy.scala
- Alphabetic
- By Inheritance
- DelayStrategy
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- def fixedDelay[T](delay: Duration): DelayStrategy[T]
Fixed delay strategy, always returns constant delay for any element.
Fixed delay strategy, always returns constant delay for any element.
- delay
value of the delay
- def linearIncreasingDelay[T](increaseStep: Duration, needsIncrease: (T) => Boolean, initialDelay: Duration, maxDelay: Duration): DelayStrategy[T]
Strategy with linear increasing delay.
Strategy with linear increasing delay. It starts with
initialDelay
for each element, increases byincreaseStep
every time whenneedsIncrease
returnstrue
up tomaxDelay
, whenneedsIncrease
returnsfalse
it resets toinitialDelay
.- increaseStep
step by which delay is increased
- needsIncrease
if
true
delay increases, iffalse
delay resets toinitialDelay
- initialDelay
initial delay for each of elements
- maxDelay
limits maximum delay
- def linearIncreasingDelay[T](increaseStep: Duration, needsIncrease: (T) => Boolean, initialDelay: Duration): DelayStrategy[T]
Strategy with linear increasing delay.
Strategy with linear increasing delay. It starts with
initialDelay
for each element, increases byincreaseStep
every time whenneedsIncrease
returnstrue
. whenneedsIncrease
returnsfalse
it resets toinitialDelay
.- increaseStep
step by which delay is increased
- needsIncrease
if
true
delay increases, iffalse
delay resets toinitialDelay
- initialDelay
initial delay for each of elements
- def linearIncreasingDelay[T](increaseStep: Duration, needsIncrease: (T) => Boolean): DelayStrategy[T]
Strategy with linear increasing delay.
Strategy with linear increasing delay. It starts with zero delay for each element, increases by
increaseStep
every time whenneedsIncrease
returnstrue
, whenneedsIncrease
returnsfalse
it resets toinitialDelay
.- increaseStep
step by which delay is increased
- needsIncrease
if
true
delay increases, iffalse
delay resets toinitialDelay