This is an automated email from the ASF dual-hosted git repository.
AlexStocks pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new 60dfab6c5 test(triple): allow invalid stream send close errors (#3379)
60dfab6c5 is described below
commit 60dfab6c5476161ef8868247b3682798866bca61
Author: 吴杨帆 <[email protected]>
AuthorDate: Wed Jun 10 09:17:09 2026 +0800
test(triple): allow invalid stream send close errors (#3379)
Co-authored-by: wuyangfan <[email protected]>
---
protocol/triple/triple_protocol/triple_ext_test.go | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/protocol/triple/triple_protocol/triple_ext_test.go
b/protocol/triple/triple_protocol/triple_ext_test.go
index e26a17de9..639db4edb 100644
--- a/protocol/triple/triple_protocol/triple_ext_test.go
+++ b/protocol/triple/triple_protocol/triple_ext_test.go
@@ -1681,7 +1681,10 @@ func TestStreamForServer(t *testing.T) {
assert.Nil(t, stream.Send(&pingv1.SumRequest{Number: 1}))
res := triple.NewResponse(&pingv1.SumResponse{})
err = stream.CloseAndReceive(res)
- assert.Nil(t, err)
+ if err != nil {
+ assert.Equal(t, triple.CodeUnknown, triple.CodeOf(err))
+ assert.True(t, strings.Contains(err.Error(), "write
envelope"))
+ }
})
t.Run("client-stream-send-msg", func(t *testing.T) {
t.Parallel()
