Skip to content

Commit b8f9bed

Browse files
authored
Merge pull request #1299 fixed race on test logs
2 parents 98b0638 + 2802d91 commit b8f9bed

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

internal/topic/topicwriterinternal/writer_reconnector_test.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -465,9 +465,7 @@ func TestWriterImpl_Reconnect(t *testing.T) {
465465
}, nil)
466466

467467
strm.EXPECT().Recv().Do(func() {
468-
t.Logf("waiting close channel: %v", name)
469468
xtest.WaitChannelClosed(t, streamClosed)
470-
t.Logf("channel closed: %v", name)
471469
}).Return(nil, errors.New("test stream closed")).MaxTimes(1)
472470

473471
return strm

0 commit comments

Comments
 (0)