Fixed data race on close topic writer

Author: rekby

internal/topic/topicwriterinternal/writer_reconnector.go

@@ -347,16 +347,17 @@ func (w *WriterReconnector) close(ctx context.Context, reason error) (resErr err
 		onDone(resErr)
 	}()
 
-	closeErr := w.queue.Close(reason)
-	if resErr == nil && closeErr != nil {
-		resErr = closeErr
-	}
-
+	// stop background work and single stream writer
 	bgErr := w.background.Close(ctx, reason)
 	if resErr == nil && bgErr != nil {
 		resErr = bgErr
 	}
 
+	closeErr := w.queue.Close(reason)
+	if resErr == nil && closeErr != nil {
+		resErr = closeErr
+	}
+
 	return resErr
 }
 

internal/topic/topicwriterinternal/writer_reconnector_test.go

@@ -632,7 +632,7 @@ func TestWriterImpl_CloseWithFlush(t *testing.T) {
 		t.Run(test.name, func(t *testing.T) {
 			xtest.TestManyTimes(t, func(t testing.TB) {
 				f(t, test.flush)
-			}, xtest.StopAfter(time.Minute))
+			})
 		})
 	}
 }