We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ac4835f commit 0bb3a9aCopy full SHA for 0bb3a9a
feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java
@@ -1,12 +1,11 @@
1
package reactivefeign.retry;
2
3
+import feign.ExceptionPropagationPolicy;
4
import org.reactivestreams.Publisher;
5
import reactor.core.Exceptions;
6
import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
7
import reactor.util.retry.Retry;
8
9
-import java.util.function.Function;
10
import java.util.function.Predicate;
11
import java.util.stream.Stream;
12
@@ -52,4 +51,9 @@ public Publisher<?> generateCompanion(Flux<RetrySignal> retrySignals) {
52
51
}
53
};
54
+
55
+ @Override
56
+ public ExceptionPropagationPolicy exceptionPropagationPolicy(){
57
+ return retryPolicy.exceptionPropagationPolicy();
58
+ }
59
0 commit comments