diff --git a/spring-cloud-gateway-server-mvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/RetryFilterFunctions.java b/spring-cloud-gateway-server-mvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/RetryFilterFunctions.java index 10ccd37bc..59ea239c3 100644 --- a/spring-cloud-gateway-server-mvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/RetryFilterFunctions.java +++ b/spring-cloud-gateway-server-mvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/RetryFilterFunctions.java @@ -22,7 +22,6 @@ import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; -import java.util.Optional; import java.util.Set; import java.util.concurrent.TimeoutException; import java.util.function.Consumer; @@ -71,9 +70,8 @@ public abstract class RetryFilterFunctions { } private static boolean isRetryableStatusCode(HttpStatusCode httpStatus, RetryConfig config) { - Optional seriesMatches = config.getSeries().stream() - .filter(series -> HttpStatus.Series.resolve(httpStatus.value()) == series).findFirst(); - return seriesMatches.isPresent(); + return config.getSeries().stream() + .anyMatch(series -> HttpStatus.Series.resolve(httpStatus.value()) == series); } public static class HttpStatusRetryPolicy extends NeverRetryPolicy {