AsyncEnumerable.AggregateAsync メソッド

定義

オーバーロード

名前 説明
AggregateAsync<TSource,TAccumulate,TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>, Func<TAccumulate,CancellationToken,ValueTask<TResult>>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。 指定したシード値が初期アキュムレータ値として使用され、指定された関数を使用して結果値が選択されます。

AggregateAsync<TSource,TAccumulate,TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,TAccumulate>, Func<TAccumulate, TResult>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。 指定したシード値が初期アキュムレータ値として使用され、指定された関数を使用して結果値が選択されます。

AggregateAsync<TSource,TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。 指定されたシード値は、初期アキュムレータ値として使用されます。

AggregateAsync<TSource,TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,TAccumulate>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。 指定されたシード値は、初期アキュムレータ値として使用されます。

AggregateAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource,TSource,CancellationToken,ValueTask<TSource>>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。

AggregateAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource,TSource,TSource>, CancellationToken)

アキュムレータ関数をシーケンスに適用します。

AggregateAsync<TSource,TAccumulate,TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>, Func<TAccumulate,CancellationToken,ValueTask<TResult>>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。 指定したシード値が初期アキュムレータ値として使用され、指定された関数を使用して結果値が選択されます。

public static System.Threading.Tasks.ValueTask<TResult> AggregateAsync<TSource,TAccumulate,TResult>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate,TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask<TAccumulate>> func, Func<TAccumulate,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask<TResult>> resultSelector, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * 'Accumulate * Func<'Accumulate, 'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask<'Accumulate>> * Func<'Accumulate, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask<'Result>> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Result>
<Extension()>
Public Function AggregateAsync(Of TSource, TAccumulate, TResult) (source As IAsyncEnumerable(Of TSource), seed As TAccumulate, func As Func(Of TAccumulate, TSource, CancellationToken, ValueTask(Of TAccumulate)), resultSelector As Func(Of TAccumulate, CancellationToken, ValueTask(Of TResult)), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TResult)

型パラメーター

TSource

ソースの要素の型。

TAccumulate

アキュムレータ値の型。

TResult

結果の値の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

seed
TAccumulate

初期アキュムレータ値。

func
Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>

各要素で呼び出されるアキュムレータ関数。

resultSelector
Func<TAccumulate,CancellationToken,ValueTask<TResult>>

最終的なアキュムレータ値を結果値に変換する関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

変換された最終的なアキュムレータ値。

例外

resultSelectornullです。

適用対象

AggregateAsync<TSource,TAccumulate,TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,TAccumulate>, Func<TAccumulate, TResult>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。 指定したシード値が初期アキュムレータ値として使用され、指定された関数を使用して結果値が選択されます。

public static System.Threading.Tasks.ValueTask<TResult> AggregateAsync<TSource,TAccumulate,TResult>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate,TSource,TAccumulate> func, Func<TAccumulate,TResult> resultSelector, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * 'Accumulate * Func<'Accumulate, 'Source, 'Accumulate> * Func<'Accumulate, 'Result> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Result>
<Extension()>
Public Function AggregateAsync(Of TSource, TAccumulate, TResult) (source As IAsyncEnumerable(Of TSource), seed As TAccumulate, func As Func(Of TAccumulate, TSource, TAccumulate), resultSelector As Func(Of TAccumulate, TResult), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TResult)

型パラメーター

TSource

ソースの要素の型。

TAccumulate

アキュムレータ値の型。

TResult

結果の値の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

seed
TAccumulate

初期アキュムレータ値。

func
Func<TAccumulate,TSource,TAccumulate>

各要素で呼び出されるアキュムレータ関数。

resultSelector
Func<TAccumulate,TResult>

最終的なアキュムレータ値を結果値に変換する関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

変換された最終的なアキュムレータ値。

例外

resultSelectornullです。

適用対象

AggregateAsync<TSource,TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。 指定されたシード値は、初期アキュムレータ値として使用されます。

public static System.Threading.Tasks.ValueTask<TAccumulate> AggregateAsync<TSource,TAccumulate>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate,TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask<TAccumulate>> func, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * 'Accumulate * Func<'Accumulate, 'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask<'Accumulate>> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Accumulate>
<Extension()>
Public Function AggregateAsync(Of TSource, TAccumulate) (source As IAsyncEnumerable(Of TSource), seed As TAccumulate, func As Func(Of TAccumulate, TSource, CancellationToken, ValueTask(Of TAccumulate)), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TAccumulate)

型パラメーター

TSource

ソースの要素の型。

TAccumulate

アキュムレータ値の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

seed
TAccumulate

初期アキュムレータ値。

func
Func<TAccumulate,TSource,CancellationToken,ValueTask<TAccumulate>>

各要素で呼び出されるアキュムレータ関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

ValueTask<TAccumulate>

最終的なアキュムレータ値。

例外

funcnullです。

適用対象

AggregateAsync<TSource,TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate,TSource,TAccumulate>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。 指定されたシード値は、初期アキュムレータ値として使用されます。

public static System.Threading.Tasks.ValueTask<TAccumulate> AggregateAsync<TSource,TAccumulate>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate,TSource,TAccumulate> func, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * 'Accumulate * Func<'Accumulate, 'Source, 'Accumulate> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Accumulate>
<Extension()>
Public Function AggregateAsync(Of TSource, TAccumulate) (source As IAsyncEnumerable(Of TSource), seed As TAccumulate, func As Func(Of TAccumulate, TSource, TAccumulate), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TAccumulate)

型パラメーター

TSource

ソースの要素の型。

TAccumulate

アキュムレータ値の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

seed
TAccumulate

初期アキュムレータ値。

func
Func<TAccumulate,TSource,TAccumulate>

各要素で呼び出されるアキュムレータ関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

ValueTask<TAccumulate>

最終的なアキュムレータ値。

例外

funcnullです。

適用対象

AggregateAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource,TSource,CancellationToken,ValueTask<TSource>>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。

public static System.Threading.Tasks.ValueTask<TSource> AggregateAsync<TSource>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, Func<TSource,TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask<TSource>> func, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * Func<'Source, 'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask<'Source>> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Source>
<Extension()>
Public Function AggregateAsync(Of TSource) (source As IAsyncEnumerable(Of TSource), func As Func(Of TSource, TSource, CancellationToken, ValueTask(Of TSource)), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TSource)

型パラメーター

TSource

ソースの要素の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

func
Func<TSource,TSource,CancellationToken,ValueTask<TSource>>

各要素で呼び出されるアキュムレータ関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

ValueTask<TSource>

最終的なアキュムレータ値。

例外

funcnullです。

source には要素が含まれています。

適用対象

AggregateAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource,TSource,TSource>, CancellationToken)

ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs
ソース:
AggregateAsync.cs

アキュムレータ関数をシーケンスに適用します。

public static System.Threading.Tasks.ValueTask<TSource> AggregateAsync<TSource>(this System.Collections.Generic.IAsyncEnumerable<TSource> source, Func<TSource,TSource,TSource> func, System.Threading.CancellationToken cancellationToken = default);
static member AggregateAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * Func<'Source, 'Source, 'Source> * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<'Source>
<Extension()>
Public Function AggregateAsync(Of TSource) (source As IAsyncEnumerable(Of TSource), func As Func(Of TSource, TSource, TSource), Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of TSource)

型パラメーター

TSource

ソースの要素の型。

パラメーター

source
IAsyncEnumerable<TSource>

集計する IAsyncEnumerable<T>

func
Func<TSource,TSource,TSource>

各要素で呼び出されるアキュムレータ関数。

cancellationToken
CancellationToken

キャンセル要求を監視する CancellationToken 。 既定値は None です。

返品

ValueTask<TSource>

最終的なアキュムレータ値。

例外

funcnullです。

source には要素が含まれています。

適用対象