修复data race

ecodeclub · Oct 19, 2023 · f9551eb · f9551eb
1 parent 4eb1b92
commit f9551eb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/e2e/base_test.go b/e2e/base_test.go
@@ -756,7 +756,10 @@ func (b *TestSuite) TestMQConsumer_Consume() {
 	err = c.Close()
 	require.NoError(b.T(), err)
 	time.Sleep(5 * time.Second)
-	assert.ElementsMatch(b.T(), wantVal, genMsg(ans, false))
+	locker.Lock()
+	val := ans
+	locker.Unlock()
+	assert.ElementsMatch(b.T(), wantVal, genMsg(val, false))
 }
 
 func genMsg(msgs []*mq.Message, hasPartitionID bool) []*mq.Message {