aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/pdsuicommon/concurrent
diff options
context:
space:
mode:
authorvlad <vlad@driver.xyz>2017-06-16 11:12:52 -0700
committervlad <vlad@driver.xyz>2017-06-16 11:12:52 -0700
commit111311fd935d9bd271c673cf10c0babe54bde8a6 (patch)
tree4742679ca244bb417e3d8fdacd51f269f4b969ae /src/main/scala/xyz/driver/pdsuicommon/concurrent
parentc1993e0f834cb4e0ccfd1dd54610ffe50de60238 (diff)
downloadrest-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')
-rw-r--r--src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala4
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)
}
}