From de7cf255b7c3af1b9767498cffadb99bc2605651 Mon Sep 17 00:00:00 2001
From: wangyu <727842003@qq.com>
Date: Wed, 26 Jan 2022 09:37:26 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E5=AE=9E=E7=8E=B0=E5=8A=A8?=
 =?UTF-8?q?=E6=80=81=E5=93=8D=E5=BA=94=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../framework/context/ReactiveContext.java    | 22 +++++++++++++++++++
 1 file changed, 22 insertions(+)
 create mode 100644 flyfish-common/src/main/java/com/flyfish/framework/context/ReactiveContext.java

diff --git a/flyfish-common/src/main/java/com/flyfish/framework/context/ReactiveContext.java b/flyfish-common/src/main/java/com/flyfish/framework/context/ReactiveContext.java
new file mode 100644
index 0000000..2fb6f2f
--- /dev/null
+++ b/flyfish-common/src/main/java/com/flyfish/framework/context/ReactiveContext.java
@@ -0,0 +1,22 @@
+package com.flyfish.framework.context;
+
+import reactor.core.publisher.Mono;
+
+/**
+ * 异步上下文
+ * 提供当前订阅联调无缝体验
+ *
+ * @author wangyu
+ */
+public class ReactiveContext {
+
+    /**
+     * 获取上下文中的共享值
+     *
+     * @param <T> 泛型，就是exchange
+     * @return 结果
+     */
+    public static <T> Mono<T> get(Class<T> clazz) {
+        return Mono.deferContextual(ctx -> ctx.hasKey(clazz) ? ctx.<Mono<T>>get(clazz) : Mono.empty());
+    }
+}