You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2026/01/18 14:16:16 UTC

(dubbo-go) branch develop updated: test: enhance triple stream validation in unit tests (#3152)

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 <ze...@gmail.com>
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
 			},