From 4332f7ffd01e1fe1d5fbde552f92642dcb2cff4e Mon Sep 17 00:00:00 2001 From: ncreep Date: Mon, 30 May 2016 13:45:07 +0300 Subject: [PATCH] JitterBackoff.forever has uses constant sleep The `sleep` value calculated by the `jitter` is now being used in `Delay`. --- src/main/scala/Policy.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/Policy.scala b/src/main/scala/Policy.scala index 22e0c15..d8be880 100644 --- a/src/main/scala/Policy.scala +++ b/src/main/scala/Policy.scala @@ -119,7 +119,7 @@ object JitterBackoff { (implicit success: Success[T], executor: ExecutionContext): Future[T] = { def run(attempt: Int, sleep: FiniteDuration): Future[T] = retry(promise, { () => - Delay(delay) { + Delay(sleep) { run(attempt + 1, jitter(delay, sleep, attempt)) }.future.flatMap(identity) })