This is an automated email from the ASF dual-hosted git repository.
wuxinfan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/main by this push:
new fd1f8d968 fix: Fix problematic error returns (#2791)
fd1f8d968 is described below
commit fd1f8d968cbeb39387f9ba84a6dd6b745b03ce98
Author: cui fliter <[email protected]>
AuthorDate: Sun Mar 9 12:34:53 2025 +0800
fix: Fix problematic error returns (#2791)
Signed-off-by: cuishuang <[email protected]>
---
protocol/triple/internal/client/common/client.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/protocol/triple/internal/client/common/client.go
b/protocol/triple/internal/client/common/client.go
index c83274ff0..0da91cb74 100644
--- a/protocol/triple/internal/client/common/client.go
+++ b/protocol/triple/internal/client/common/client.go
@@ -65,7 +65,7 @@ func testBidiStream(cli greettriple.GreetService) error {
return err
}
if sendErr := stream.Send(&greet.GreetStreamRequest{Name: "triple"});
sendErr != nil {
- return err
+ return sendErr
}
resp, err := stream.Recv()
if err != nil {
@@ -89,7 +89,7 @@ func testClientStream(cli greettriple.GreetService) error {
}
for i := 0; i < 5; i++ {
if sendErr := stream.Send(&greet.GreetClientStreamRequest{Name:
"triple"}); sendErr != nil {
- return err
+ return sendErr
}
}
resp, err := stream.CloseAndRecv()