Skip to content

Commit ccf5d3d

Browse files
committed
Issue ReactiveX#458: Fixed missing Context propagation in AbstractSubscriber.
1 parent 8dfd276 commit ccf5d3d

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

resilience4j-reactor/src/main/java/io/github/resilience4j/reactor/AbstractSubscriber.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import org.reactivestreams.Subscription;
1919
import reactor.core.CoreSubscriber;
2020
import reactor.core.publisher.BaseSubscriber;
21+
import reactor.util.context.Context;
2122

2223
/**
2324
* Heavily inspired by {@link reactor.core.publisher.BaseSubscriber}
@@ -42,6 +43,11 @@ protected void hookOnSubscribe(Subscription subscription){
4243
downstreamSubscriber.onSubscribe(this);
4344
}
4445

46+
@Override
47+
public Context currentContext() {
48+
return downstreamSubscriber.currentContext();
49+
}
50+
4551
@Override
4652
public String toString() {
4753
return getClass().getSimpleName();

0 commit comments

Comments
 (0)