fixes #659

PlaytikaOSS · Sep 4, 2024 · 0bb3a9a · 0bb3a9a
1 parent ac4835f
commit 0bb3a9a
Showing 1 changed file with 6 additions and 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
@@ -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<RetrySignal> retrySignals) {
             }
         };
     }
+
+    @Override
+    public ExceptionPropagationPolicy exceptionPropagationPolicy(){
+        return retryPolicy.exceptionPropagationPolicy();
+    }
 }