From ccf5d3d6afeba24ce6136b65fe0c8ddf0884715f Mon Sep 17 00:00:00 2001
From: Robert Winkler <robwin@t-online.de>
Date: Sun, 19 May 2019 18:44:42 +0200
Subject: [PATCH] Issue #458: Fixed missing Context propagation in
 AbstractSubscriber.

---
 .../io/github/resilience4j/reactor/AbstractSubscriber.java  | 6 ++++++
 1 file changed, 6 insertions(+)

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();