Skip to content

Commit 487b2f7

Browse files
committed
Address comments
1 parent 6db9e19 commit 487b2f7

File tree

4 files changed

+9
-13
lines changed

4 files changed

+9
-13
lines changed

core/sdk-core/src/main/java/software/amazon/awssdk/core/retry/RetryPolicy.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -55,12 +55,8 @@ private RetryPolicy(BuilderImpl builder) {
5555
this.throttlingBackoffStrategy = builder.throttlingBackoffStrategy;
5656
this.numRetries = builder.numRetries;
5757
this.retryConditionFromBuilder = builder.retryCondition;
58-
if (numRetries == 0) {
59-
this.retryCondition = retryConditionFromBuilder;
60-
} else {
61-
this.retryCondition = AndRetryCondition.create(MaxNumberOfRetriesCondition.create(numRetries),
62-
retryConditionFromBuilder);
63-
}
58+
this.retryCondition = AndRetryCondition.create(MaxNumberOfRetriesCondition.create(numRetries),
59+
retryConditionFromBuilder);
6460
}
6561

6662
public RetryCondition retryCondition() {

core/sdk-core/src/main/java/software/amazon/awssdk/core/retry/conditions/AndRetryCondition.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515

1616
package software.amazon.awssdk.core.retry.conditions;
1717

18-
import java.util.ArrayList;
1918
import java.util.Collections;
20-
import java.util.List;
19+
import java.util.HashSet;
20+
import java.util.Set;
2121
import software.amazon.awssdk.annotations.SdkPublicApi;
2222
import software.amazon.awssdk.core.retry.RetryPolicyContext;
2323
import software.amazon.awssdk.utils.ToString;
@@ -29,7 +29,7 @@
2929
@SdkPublicApi
3030
public final class AndRetryCondition implements RetryCondition {
3131

32-
private List<RetryCondition> conditions = new ArrayList<>();
32+
private Set<RetryCondition> conditions = new HashSet<>();
3333

3434
private AndRetryCondition(RetryCondition... conditions) {
3535
Collections.addAll(this.conditions, Validate.notEmpty(conditions, "%s cannot be empty.", "conditions"));

core/sdk-core/src/main/java/software/amazon/awssdk/core/retry/conditions/OrRetryCondition.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515

1616
package software.amazon.awssdk.core.retry.conditions;
1717

18-
import java.util.ArrayList;
1918
import java.util.Collections;
20-
import java.util.List;
19+
import java.util.HashSet;
20+
import java.util.Set;
2121
import software.amazon.awssdk.annotations.SdkPublicApi;
2222
import software.amazon.awssdk.core.retry.RetryPolicyContext;
2323
import software.amazon.awssdk.utils.ToString;
@@ -28,7 +28,7 @@
2828
@SdkPublicApi
2929
public final class OrRetryCondition implements RetryCondition {
3030

31-
private List<RetryCondition> conditions = new ArrayList<>();
31+
private Set<RetryCondition> conditions = new HashSet<>();
3232

3333
private OrRetryCondition(RetryCondition... conditions) {
3434
Collections.addAll(this.conditions, conditions);

core/sdk-core/src/test/java/software/amazon/awssdk/core/retry/RetryPolicyTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void throttlingDelay_delegatesToThrottlingBackoffStrategy() {
7575
public void nonRetryPolicy_shouldUseNullCondition() {
7676
RetryPolicy noneRetry = RetryPolicy.none();
7777

78-
assertThat(noneRetry.retryCondition()).isEqualTo(RetryCondition.none());
78+
assertThat(noneRetry.retryCondition().shouldRetry(RetryPolicyContext.builder().build())).isFalse();
7979
assertThat(noneRetry.numRetries()).isZero();
8080
assertThat(noneRetry.backoffStrategy()).isEqualTo(BackoffStrategy.none());
8181
assertThat(noneRetry.throttlingBackoffStrategy()).isEqualTo(BackoffStrategy.none());

0 commit comments

Comments
 (0)