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