From 129b4fa2fd5aea13a0365d696c83f723d69413c7 Mon Sep 17 00:00:00 2001 From: earthchen Date: Fri, 14 Apr 2023 17:20:30 +0800 Subject: [PATCH] fix tri stub exception (#12093) * fix tri stub exception * fix --- .../org/apache/dubbo/rpc/stub/UnaryStubMethodHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/stub/UnaryStubMethodHandler.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/stub/UnaryStubMethodHandler.java index f2bff904f1..81e069fa63 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/stub/UnaryStubMethodHandler.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/stub/UnaryStubMethodHandler.java @@ -34,7 +34,11 @@ public class UnaryStubMethodHandler implements StubMethodHandler { T request = (T) arguments[0]; CompletableFuture future = new CompletableFuture<>(); StreamObserver responseObserver = new FutureToObserverAdaptor<>(future); - func.accept(request, responseObserver); + try { + func.accept(request, responseObserver); + } catch (Throwable e) { + future.completeExceptionally(e); + } return future; } }