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

Reply via email to