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 abd1b32b0 test: enhance triple stream validation in unit tests (#3152)
abd1b32b0 is described below
commit abd1b32b0ad5d65d023724de4a5d2830cafee77e
Author: Zerui Yang <[email protected]>
AuthorDate: Sun Jan 18 22:16:11 2026 +0800
test: enhance triple stream validation in unit tests (#3152)
---
protocol/triple/triple_protocol/triple_ext_test.go | 3 +++
1 file changed, 3 insertions(+)
diff --git a/protocol/triple/triple_protocol/triple_ext_test.go
b/protocol/triple/triple_protocol/triple_ext_test.go
index 6a08d0da6..bcc506342 100644
--- a/protocol/triple/triple_protocol/triple_ext_test.go
+++ b/protocol/triple/triple_protocol/triple_ext_test.go
@@ -1658,6 +1658,9 @@ func TestStreamForServer(t *testing.T) {
t.Parallel()
client, server := newPingServer(&pluggablePingServer{
sum: func(ctx context.Context, stream
*triple.ClientStream) (*triple.Response, error) {
+ // First receive the client's message to ensure
the stream is established
+ assert.True(t,
stream.Receive(&pingv1.SumRequest{}))
+ // Now try to send non-proto message, which
should fail
assert.NotNil(t,
stream.Conn().Send("not-proto"))
return
triple.NewResponse(&pingv1.SumResponse{}), nil
},
