diff options
author | vlad <vlad@driver.xyz> | 2017-06-16 11:12:52 -0700 |
---|---|---|
committer | vlad <vlad@driver.xyz> | 2017-06-16 11:12:52 -0700 |
commit | 111311fd935d9bd271c673cf10c0babe54bde8a6 (patch) | |
tree | 4742679ca244bb417e3d8fdacd51f269f4b969ae /src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala | |
parent | c1993e0f834cb4e0ccfd1dd54610ffe50de60238 (diff) | |
download | rest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.tar.gz rest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.tar.bz2 rest-query-111311fd935d9bd271c673cf10c0babe54bde8a6.zip |
Update PDS UI common code to be up to datev0.1.5
Diffstat (limited to 'src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala')
-rw-r--r-- | src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala index a98d2cd..528be59 100644 --- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala +++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala @@ -12,6 +12,7 @@ import xyz.driver.pdsuicommon.logging._ import scala.concurrent.duration.{Duration, FiniteDuration} import scala.concurrent.{ExecutionContext, Future} +import scala.util.Try object BridgeUploadQueueRepositoryAdapter { @@ -39,7 +40,8 @@ object BridgeUploadQueueRepositoryAdapter { } private def intervalFor(attempt: Int): Duration = { - startInterval * Math.pow(intervalFactor, attempt.toDouble) + Try(startInterval * Math.pow(intervalFactor, attempt.toDouble)) + .getOrElse(maxInterval) } } |