Привет всем. У меня есть список имён файлов. Я должен

Question

Привет всем. У меня есть список имён файлов. Я должен

по именам файлов найти их, и вернуть стримы из них. На выходе должен получиться список стримов. Каждый отдельный поток я получаю через метод, возвращающий Task<Stream>.
Кажется, сюда напрашивается AsyncEnumerable, но я что-то не понимаю как мне его заюзать.

Вот такой вариант ниже - он же не имеет смысла, так?

async IAsyncEnumerable<Stream> GetStreams(List<string> paths) {
foreach (var path in paths) {
yield return await fileService.GetStream(path);
}
}

#backend #dot #programming #russian

0

21.04.2021

12 ответов

3 просмотра

Михаил Проказин Автор вопроса

Проще говоря, у меня есть метод A -> Task<B>, как мне с его использованием получить метод IEnumerable<A> -> IAsyncEnumerable<B>?

0

21.04.2021

Михаил Проказин Автор вопроса

Михаил Проказин
Проще говоря, у меня есть метод A -> Task<B>, как ...

Нашёл такой вариант: public static async IAsyncEnumerable<T> ParallelEnumerateAsync<T>( this IEnumerable<Task<T>> tasks) { var remaining = new List<Task<T>>(tasks); while (remaining.Count != 0) { var task = await Task.WhenAny(remaining); remaining.Remove(task); yield return (await task); } } Вопрос закрыт, если никто не захочет ничего добавить.

0

21.04.2021

Михаил Проказин Автор вопроса

Danil S
await foreach (var item in iAsyncEnumerable<Collec...

У меня на входе нет async enumerable. Мне его самому нужно сделать. Пример который мне вроде подходит выше.

0

21.04.2021

Danil S

Михаил Проказин
Нашёл такой вариант: public static async IAsyncEnu...

remaining.Remove(task); - выглядит не очень тредсейф

0

21.04.2021