Issue ReactiveX#458: Fixed missing Context propagation in AbstractSub…

…scriber.
jihoonson · May 19, 2019 · ccf5d3d · ccf5d3d
1 parent 8dfd276
commit ccf5d3d
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/resilience4j-reactor/src/main/java/io/github/resilience4j/reactor/AbstractSubscriber.java b/resilience4j-reactor/src/main/java/io/github/resilience4j/reactor/AbstractSubscriber.java
@@ -18,6 +18,7 @@
 import org.reactivestreams.Subscription;
 import reactor.core.CoreSubscriber;
 import reactor.core.publisher.BaseSubscriber;
+import reactor.util.context.Context;
 
 /**
  * Heavily inspired by {@link reactor.core.publisher.BaseSubscriber}
@@ -42,6 +43,11 @@ protected void hookOnSubscribe(Subscription subscription){
         downstreamSubscriber.onSubscribe(this);
     }
 
+    @Override
+    public Context currentContext() {
+        return downstreamSubscriber.currentContext();
+    }
+
     @Override
     public String toString() {
         return getClass().getSimpleName();