We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a073684 commit 3b89ae3Copy full SHA for 3b89ae3
1 file changed
remoting/remoting-triple/src/main/java/com/alipay/sofa/rpc/server/triple/GenericServiceImpl.java
@@ -120,7 +120,11 @@ public StreamObserver<Request> genericBiStream(StreamObserver<Response> response
120
121
SofaResponse sofaResponse = invoker.invoke(sofaRequest);
122
123
- SofaStreamObserver<Object> clientHandler = (SofaStreamObserver<Object>) sofaResponse.getAppResponse();
+ Object appResponse = sofaResponse.getAppResponse();
124
+ if (appResponse instanceof Exception) {
125
+ throw (Exception) appResponse;
126
+ }
127
+ SofaStreamObserver<Object> clientHandler = (SofaStreamObserver<Object>) appResponse;
128
129
return new StreamObserver<Request>() {
130
private volatile Serializer serializer = null;
0 commit comments