fix test

art22m · art22m · commit e8f20d421ce5 · 2024-01-27T16:04:10.000+03:00
diff --git a/internal/topic/topicwriterinternal/writer_reconnector_test.go b/internal/topic/topicwriterinternal/writer_reconnector_test.go
@@ -516,7 +516,7 @@ func TestWriterImpl_Reconnect(t *testing.T) {
 		err := w.Write(ctx, newTestMessages(1))
 		require.NoError(t, err)
 
-		xtest.WaitChannelClosed(t, connectionLoopStopped)
+		xtest.WaitChannelClosedWithTimeout(t, connectionLoopStopped, 4*time.Second)
 	})
 }
 

Original file line number	Diff line number	Diff line change
`@@ -516,7 +516,7 @@ func TestWriterImpl_Reconnect(t *testing.T) {`
`516`	`516`	`err := w.Write(ctx, newTestMessages(1))`
`517`	`517`	`require.NoError(t, err)`
`518`	`518`
`519`		`- xtest.WaitChannelClosed(t, connectionLoopStopped)`
	`519`	`+ xtest.WaitChannelClosedWithTimeout(t, connectionLoopStopped, 4*time.Second)`
`520`	`520`	`})`
`521`	`521`	`}`
`522`	`522`