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
index dad0ae0cdf..c48abda2ec 100644
--- 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();