From b12b7a32646f43637990e4e6de0d1c3006358a18 Mon Sep 17 00:00:00 2001 From: Ian Hu Date: Fri, 19 Apr 2019 17:14:27 +0800 Subject: [PATCH] Remove unnecessary lambda Remove unnecessary lambda --- .../resilience4j/ReactiveResilience4JCircuitBreaker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java b/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java index 504227e..30fcd5e 100644 --- a/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java +++ b/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java @@ -67,7 +67,7 @@ public class ReactiveResilience4JCircuitBreaker implements ReactiveCircuitBreake config.getTimeLimiterConfig().getTimeoutDuration().toMillis(), t)); if (fallback != null) { - toReturn = toReturn.onErrorResume(t -> fallback.apply(t)); + toReturn = toReturn.onErrorResume(fallback); } return toReturn; } @@ -86,7 +86,7 @@ public class ReactiveResilience4JCircuitBreaker implements ReactiveCircuitBreake config.getTimeLimiterConfig().getTimeoutDuration().toMillis(), t)); if (fallback != null) { - toReturn = toReturn.onErrorResume(t -> fallback.apply(t)); + toReturn = toReturn.onErrorResume(fallback); } return toReturn; }