Merge pull request ReactiveX#11 from charithe/master

Fix to allow retry durations over 10 ms

Author: RobWin

src/main/java/javaslang/retry/RetryContext.java

@@ -93,8 +93,8 @@ public Builder maxAttempts(int maxAttempts) {
         }
 
         public Builder waitDuration(Duration waitDuration) {
-            if (waitDuration.getSeconds() < 0.01) {
-                throw new IllegalArgumentException("waitDurationInOpenState must be at least than 10[ms]");
+            if (waitDuration.toMillis() < 10) {
+                throw new IllegalArgumentException("waitDurationInOpenState must be at least 10ms");
             }
             this.waitDuration = waitDuration;
             return this;

src/test/java/javaslang/retry/RetryBuilderTest.java

@@ -22,6 +22,8 @@
 
 import java.time.Duration;
 
+import static org.assertj.core.api.Assertions.assertThat;
+
 public class RetryBuilderTest {
 
     @Test(expected = IllegalArgumentException.class)
@@ -33,4 +35,21 @@ public void zeroMaxAttemptsShouldFail() {
     public void zeroWaitIntervalShouldFail() {
         Retry.custom().waitDuration(Duration.ofMillis(0)).build();
     }
+
+    @Test(expected = IllegalArgumentException.class)
+    public void WaitIntervalUnderTenMillisShouldFail() {
+        Retry.custom().waitDuration(Duration.ofMillis(5)).build();
+    }
+
+    @Test
+    public void waitIntervalOfTenMillisShouldSucceed() {
+        Retry retryCtx = Retry.custom().waitDuration(Duration.ofMillis(10)).build();
+        assertThat(retryCtx).isNotNull();
+    }
+
+    @Test
+    public void waitIntervalOverTenMillisShouldSucceed() {
+        Retry retryCtx = Retry.custom().waitDuration(Duration.ofSeconds(10)).build();
+        assertThat(retryCtx).isNotNull();
+    }
 }