Es un poco complicado obtener datos de CosmosDb FeedIterator convertidos en IEnumerable de una manera simple y reutilizable sin tener que escribir bucles e iteraciones por todas partes.
El ejemplo oficial de Microsoft, que no es tan claro como me gusta, se ve así:
using (FeedIterator setIterator = container.GetItemLinqQueryable<Book>() .Where(b => b.Title == "War and Peace") .ToFeedIterator()) { //Asynchronous query execution while (setIterator.HasMoreResults) { foreach(var item in await setIterator.ReadNextAsync()) { Console.WriteLine(item.Price); } } }Me gustaría tener un oneliner reutilizable y no encontré uno, así que escribí uno.
Especialmente cuando se va a usar en una API .NET, así que escribí un método de extensión para convertir FeedIterator a IAsyncEnumerable que puede usar el
(En C# 8 puede devolver IAsyncEnumerable desde su API, pero si necesita compatibilidad con netstandard2.0 como yo, puede convertir IAsyncEnumerable en un IEnumerable normal)
Así es como lo resolví:
Método de extensión:
public static class CosmosDbExtensions { /// <summary> /// Convert a feed iterator to IAsyncEnumerable /// </summary> /// <typeparam name="TModel"></typeparam> /// <param name="setIterator"></param> /// <returns></returns> public static async IAsyncEnumerable<TModel> ToAsyncEnumerable<TModel>(this FeedIterator<TModel> setIterator) { while (setIterator.HasMoreResults) foreach (var item in await setIterator.ReadNextAsync()) { yield return item; } } }Para devolver IAsyncEnumerable:
public virtual IAsyncEnumerable<TModel> Query() { Container container = GetContainer(); // Your code to get container return container.GetItemLinqQueryable<TModel>().ToFeedIterator().ToAsyncEnumerable(); }Para devolver IEnumerable:
public virtual async Task<IEnumerable<TModel>> Query() { Container container = GetContainer(); // Your code to get container using (var feedIterator = container.GetItemLinqQueryable<TModel>().ToFeedIterator()) { return await feedIterator.ToAsyncEnumerable().ToListAsync(); } }(Más sobre .ToListAsync() del paquete System.Linq.Async en este hilo )