Skip to content

Commit

Permalink
fix: merge problems
Browse files Browse the repository at this point in the history
  • Loading branch information
V-Staykov committed Dec 12, 2024
1 parent 725e075 commit 5397827
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions zk/datastream/client/stream_client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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()
Expand Down

0 comments on commit 5397827

Please sign in to comment.