From 23b89d8c56ef8c03b7fb8ff74e292aaafadfaedc Mon Sep 17 00:00:00 2001
From: wangyu <727842003@qq.com>
Date: Tue, 7 Dec 2021 19:53:33 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E5=85=BC=E5=AE=B9webflux=E7=9A=84?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97=E5=88=87=E9=9D=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../flyfish/framework/logging/advice/LogAdvice.java    | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git a/flyfish-logging/src/main/java/com/flyfish/framework/logging/advice/LogAdvice.java b/flyfish-logging/src/main/java/com/flyfish/framework/logging/advice/LogAdvice.java
index 18e9207..67d4aec 100644
--- a/flyfish-logging/src/main/java/com/flyfish/framework/logging/advice/LogAdvice.java
+++ b/flyfish-logging/src/main/java/com/flyfish/framework/logging/advice/LogAdvice.java
@@ -65,15 +65,9 @@ public class LogAdvice {
         if (null != result) {
             // 判断结果是否是publisher
             if (result instanceof Mono) {
-                ((Mono<?>) result).subscribe(data -> {
-                    context.setResult(data);
-                    context.end();
-                });
+                ((Mono<?>) result).subscribe(context::setResult, context::setError, context::end);
             } else if (result instanceof Flux) {
-                ((Flux<?>) result).collectList().subscribe(list -> {
-                    context.setResult(list);
-                    context.end();
-                });
+                ((Flux<?>) result).collectList().subscribe(context::setResult, context::setError, context::end);
             } else {
                 context.setResult(result);
                 context.end();