public static Task<object> CustomAggregateAsync<T>(
    this IQueryable<T> query,
    string customAggregateName,
    Expression<Func<T, object>>[] arguments,
    CancellationToken cancellationToken
)

<ExtensionAttribute>
Public Shared Function CustomAggregateAsync(Of T)(
    query As IQueryable(Of T),
    customAggregateName As String,
    arguments As Expression(Of Func(Of T, Object))(),
    cancellationToken As CancellationToken
) As Task(Of Object)