add fuseable marker for Mono.currentContext since scalar sub

reactor · Jul 18, 2017 · 8e75104 · 8e75104
1 parent 7cc4d54
commit 8e75104
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/MonoCurrentContext.java b/reactor-core/src/main/java/reactor/core/publisher/MonoCurrentContext.java
@@ -17,12 +17,13 @@
 package reactor.core.publisher;
 
 import reactor.core.CoreSubscriber;
+import reactor.core.Fuseable;
 import reactor.util.context.Context;
 
 /**
  * Materialize current {@link Context} from the subscribing flow
  */
-final class MonoCurrentContext extends Mono<Context> {
+final class MonoCurrentContext extends Mono<Context> implements Fuseable {
 
 	static final MonoCurrentContext INSTANCE = new MonoCurrentContext();