increase timeout in stream client tests

hexoscott · hexoscott · commit 7a3ce9fcac38 · 2025-02-05T15:53:35.000Z
diff --git a/zk/datastream/client/stream_client_test.go b/zk/datastream/client/stream_client_test.go
@@ -118,7 +118,7 @@ func TestStreamClientReadResultEntry(t *testing.T) {
 	}
 
 	for _, testCase := range testCases {
-		c := NewClient(context.Background(), "", false, 0, 500*time.Millisecond, 0)
+		c := NewClient(context.Background(), "", false, 0, 2*time.Second, 0)
 		server, conn := net.Pipe()
 		defer server.Close()
 		defer c.Stop()

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ func TestStreamClientReadResultEntry(t *testing.T) {`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`for _, testCase := range testCases {`
`121`		`- c := NewClient(context.Background(), "", false, 0, 500*time.Millisecond, 0)`
	`121`	`+ c := NewClient(context.Background(), "", false, 0, 2*time.Second, 0)`
`122`	`122`	`server, conn := net.Pipe()`
`123`	`123`	`defer server.Close()`
`124`	`124`	`defer c.Stop()`