aboutsummaryrefslogtreecommitdiff
path: root/src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala')
-rw-r--r--src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala b/src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala
index 48a4eaf..d0dbb04 100644
--- a/src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala
+++ b/src/test/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapterSuite.scala
@@ -19,7 +19,7 @@ class BridgeUploadQueueRepositoryAdapterSuite extends BaseSuite {
"Strategy" - {
"LimitExponential" - {
- "calculateNextInterval" - {
+ "on" - {
val strategy = Strategy.LimitExponential(
startInterval = 10.seconds,
intervalFactor = 1.4,
@@ -40,6 +40,10 @@ class BridgeUploadQueueRepositoryAdapterSuite extends BaseSuite {
"should limit intervals" in {
assert(strategy.on(20) == OnAttempt.Continue(strategy.maxInterval))
}
+
+ "should not fail, if there is many attempts" in {
+ assert(strategy.on(1000) == OnAttempt.Continue(strategy.maxInterval))
+ }
}
}
}