У меня есть функция, которая получает последовательность элементов:
List<MyType> GetPage(int pageNr) {...}
Чтобы получить все доступные предметы, вы можете сделать что-то вроде:
IEnumerable<MyType> FetchMyItems()
{
int pageNr = 0;
var fetchedItems = GetPage(pageNr);
while (fetchedItems.Any()
{ // there are items to return
// yield return the fetched items:
foreach (var fetchedItem in fetchedItems)
yield return fetchedItems;
// get the next page
++pageNr;
fetchedItems = GetPage(pageNr)
}
}
Используя этот метод, моим пользователям больше не придется извлекать элементы на странице, если им нужно всего несколько элементов, будет выбрана только первая страница. Дополнительные страницы будут загружаться автоматически, когда им потребуется больше элементов. Недостатком, конечно, является то, что я иногда получаю еще несколько предметов, которые не будут использоваться.
Я хочу асинхронную версию для этого
Итак, у меня есть следующий GetPage:
async Task<List<MyType>> GetPageAsync(int pageNr) {...}
Насколько я понимаю из IEnumerable, он не создает результирующую последовательность, а только создает возможность перечислить эту последовательность.
Это перечисление выполняется явно с использованием foreach или неявно с использованием функций LINQ, таких как ToList, ToArray, а также таких функций, как FirstOrDefault, Any, Sum
.
var fetchItemTasks = FetchMyItemsAsync();
foreach (var fetchItemTask in fetchedItemTasks)
{
MyType fetchedItem = await fetchItemTask;
Process(fetchedItem);
}
Или, если вы сделаете этот низкий уровень:
var myitemsEnumerable = fetchMyItemsAsync();
// don't await yet, only create the possibility to enumerate
var enumerator = myItemsEnumerable.GetEnumerator();
while (enumerator.MoveNext())
{ // there is an item available in current:
Task<MyType> task = enumerator.Current;
return task;
}
Глядя на это, кажется, что функция должна возвращать не Task<IEnumerable<MyType>>
, а IEnumerable<Task<MyType>>
, если вы хотите получить доступ к элементу, вам придется ждать этого.
Следовательно, функция, возвращающая возможность перечисления ожидаемых элементов, сама по себе не является асинхронной. Вы не ждете перечисляемого, это перечисляемое может быть создано без доступа к медленным провайдерам, таким как база данных. Элементы перечислимой последовательности являются ожидаемыми:
IEnumerable<Task<MyType>> FetchMyItems()
{
int pageNr = 0;
Task<List<MyType>> fetchItemTask = GetPageAsync(pageNr);
И сейчас? Если я await fetchItemTask
, элементы уже локальны, ждать больше нечего. Если я fetchItemTask.Wait()
, функция блокируется.
FirstOrDefault
? Будет ли онTake(2000)
? Следовательно, я не хочу получать больше страниц, чем необходимо. Если он перечислит только несколько первых элементов, то одной страницы будет достаточно. Entity Framework имеет ListAsync,
FirstOrDefaultAsync и т. д. Чтобы иметь возможность создавать подобные функции, мне нужна базовая асинхронная функция, которая возвращает IEnumerable 15.05.2018