From 0bb3a9a2b6e986af8228859f082f8eb30b3136e9 Mon Sep 17 00:00:00 2001 From: skarpenko Date: Wed, 4 Sep 2024 11:32:35 +0300 Subject: [PATCH] fixes https://github.com/PlaytikaOSS/feign-reactive/issues/659 --- .../reactivefeign/retry/FilteredReactiveRetryPolicy.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java b/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java index f81767be..be114fca 100644 --- a/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java +++ b/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java @@ -1,12 +1,11 @@ package reactivefeign.retry; +import feign.ExceptionPropagationPolicy; import org.reactivestreams.Publisher; import reactor.core.Exceptions; import reactor.core.publisher.Flux; -import reactor.core.publisher.Mono; import reactor.util.retry.Retry; -import java.util.function.Function; import java.util.function.Predicate; import java.util.stream.Stream; @@ -52,4 +51,9 @@ public Publisher generateCompanion(Flux retrySignals) { } }; } + + @Override + public ExceptionPropagationPolicy exceptionPropagationPolicy(){ + return retryPolicy.exceptionPropagationPolicy(); + } }