|
|
@ -4,9 +4,9 @@ using System.Threading.Tasks;
|
|
|
|
|
|
|
|
|
|
|
|
namespace DiscordChatExporter.Core.Utils.Extensions;
|
|
|
|
namespace DiscordChatExporter.Core.Utils.Extensions;
|
|
|
|
|
|
|
|
|
|
|
|
public static class AsyncExtensions
|
|
|
|
public static class AsyncCollectionExtensions
|
|
|
|
{
|
|
|
|
{
|
|
|
|
private static async ValueTask<IReadOnlyList<T>> AggregateAsync<T>(
|
|
|
|
private static async ValueTask<IReadOnlyList<T>> CollectAsync<T>(
|
|
|
|
this IAsyncEnumerable<T> asyncEnumerable)
|
|
|
|
this IAsyncEnumerable<T> asyncEnumerable)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var list = new List<T>();
|
|
|
|
var list = new List<T>();
|
|
|
@ -19,5 +19,5 @@ public static class AsyncExtensions
|
|
|
|
|
|
|
|
|
|
|
|
public static ValueTaskAwaiter<IReadOnlyList<T>> GetAwaiter<T>(
|
|
|
|
public static ValueTaskAwaiter<IReadOnlyList<T>> GetAwaiter<T>(
|
|
|
|
this IAsyncEnumerable<T> asyncEnumerable) =>
|
|
|
|
this IAsyncEnumerable<T> asyncEnumerable) =>
|
|
|
|
asyncEnumerable.AggregateAsync().GetAwaiter();
|
|
|
|
asyncEnumerable.CollectAsync().GetAwaiter();
|
|
|
|
}
|
|
|
|
}
|