We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 98b0638 commit 2802d91Copy full SHA for 2802d91
internal/topic/topicwriterinternal/writer_reconnector_test.go
@@ -465,9 +465,7 @@ func TestWriterImpl_Reconnect(t *testing.T) {
465
}, nil)
466
467
strm.EXPECT().Recv().Do(func() {
468
- t.Logf("waiting close channel: %v", name)
469
xtest.WaitChannelClosed(t, streamClosed)
470
- t.Logf("channel closed: %v", name)
471
}).Return(nil, errors.New("test stream closed")).MaxTimes(1)
472
473
return strm
0 commit comments