IAsyncCursor 如何与 mongodb c# 驱动程序一起用于迭代

你有3个 Select :

1. 使用内置驱动程序方法(例如ForEachAsync、ToListAsync).
2. 在C#8.0及更高版本上，您可以将IAsyncCursor转换为IAsyncEnumerable，并使用await foreach或任何异步LINQ运算符.
3. 迭代IAsyncCursor次.

Built-in Driver Methods

对于IAsyncCursor，驱动程序有一些类似LINQ的扩展方法，比如AnyAsync、ToListAsync等.对于迭代，它有ForEachAsync:

var cursor = await client.ListDatabasesAsync();
await cursor.ForEachAsync(db => Console.WriteLine(db["name"]));

Converting to IAsyncEnumerable

在C#8.0及更高版本上，使用await foreach进行迭代(并使用异步LINQ)要好得多.这需要将IAsyncCursor包裹在IAsyncEnumerable中.

var cursor = await client.ListDatabasesAsync();
await foreach (var db in cursor.ToAsyncEnumerable())
{
    Console.WriteLine(db["name"]);
}

Custom iteration

C#中的传统迭代是用IEnumerable和foreach完成的.foreach是编译器的语法糖.实际上是对GetEnumerator、using范围和while循环的调用:

using (var enumerator = enumerable.GetEnumerator())
{
    while (enumerator.MoveNext())
    {
        var current = enumerator.Current;
        // use current.
    }
}

IAsyncCursor等于IEnumerator(IEnumerable.GetEnumerator的结果)，IAsyncCursorSource等于IEnumerable.不同之处在于，它们支持async(并在每次迭代中获得一批，而不仅仅是一个项目).所以你可以自己实现整个usingwhile循环:

IAsyncCursorSource<int> cursorSource = null;

using (var asyncCursor = await cursorSource.ToCursorAsync())
{
    while (await asyncCursor.MoveNextAsync())
    {
        foreach (var current in asyncCursor.Current)
        {
            // use current
        }
    }
}