我想集成测试一个在ElasticSearch中存储数据的类。通常，我想使用测试类添加一些数据，然后检查Elastic上是否存在数据。
测试方法示例：

[SetUp]
public void Setup()
{
    ElasticClient.DeleteByQuery(Indices.Index(IndexName), d =>
        d.Query(x => x.MatchAll())
    );
}

[Test]
public async Task GetAllConversations_ShouldReturnAllConversations()
{
    // Arrange
    Guid[] randomGuids = new[]
    {
        Guid.NewGuid(),
        Guid.NewGuid(),
        Guid.NewGuid(),
        Guid.NewGuid(),
    };

    foreach (var randomGuid in randomGuids)
    {
        await _conversationStorage.AddMessage(randomGuid, new Message()
        {
            Text = "test",
            Type = MessageType.UserMade
        });
    }

    // Act
    var result = await _sut.GetAllConversations();
    
    // Assert
    Assert.That(result?.Conversations.Count, Is.EqualTo(4));
}

（AddMessage在内部执行IndexAsync）
我的问题是，我的方法似乎是不确定的。它通常会通过（我可以看到数据出现在Elastic上），但有时不会。再次运行它会使测试再次通过。
我能否以某种方式确保最近添加的所有数据都在Elastic上建立了索引，并且我可以安全地执行“Assert”检查？
我使用Elastic.Clients.Elasticsearch .NET库和ElasticSearch版本8.10.2