From 5397827c899894471bcb618c2c9ca509a0ea8b19 Mon Sep 17 00:00:00 2001 From: Valentin Staykov Date: Thu, 12 Dec 2024 12:01:20 +0000 Subject: [PATCH] fix: merge problems --- zk/datastream/client/stream_client_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/zk/datastream/client/stream_client_test.go b/zk/datastream/client/stream_client_test.go index 3a16e6c453f..40efa394dc6 100644 --- a/zk/datastream/client/stream_client_test.go +++ b/zk/datastream/client/stream_client_test.go @@ -51,7 +51,7 @@ func TestStreamClientReadHeaderEntry(t *testing.T) { for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { - c := NewClient(context.Background(), "", 0, 500*time.Millisecond, 0) + c := NewClient(context.Background(), "", false, 0, 500*time.Millisecond, 0) server, conn := net.Pipe() defer server.Close() defer c.Stop() @@ -119,7 +119,7 @@ func TestStreamClientReadResultEntry(t *testing.T) { for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { - c := NewClient(context.Background(), "", 0, 500*time.Millisecond, 0) + c := NewClient(context.Background(), "", false, 0, 500*time.Millisecond, 0) server, conn := net.Pipe() defer server.Close() defer c.Stop() @@ -192,7 +192,7 @@ func TestStreamClientReadFileEntry(t *testing.T) { } for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { - c := NewClient(context.Background(), "", 0, 500*time.Millisecond, 0) + c := NewClient(context.Background(), "", false, 0, 500*time.Millisecond, 0) server, conn := net.Pipe() defer c.Stop() defer server.Close()