|
@@ -10,32 +10,30 @@ namespace System.Linq
|
|
|
{
|
|
|
public static partial class AsyncEnumerable
|
|
|
{
|
|
|
- public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
|
|
|
+ public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
- if (predicate == null)
|
|
|
- throw Error.ArgumentNull(nameof(predicate));
|
|
|
|
|
|
- return AnyCore(source, predicate, CancellationToken.None);
|
|
|
+ return AnyCore(source, CancellationToken.None);
|
|
|
}
|
|
|
|
|
|
- public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<bool>> predicate)
|
|
|
+ public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
- if (predicate == null)
|
|
|
- throw Error.ArgumentNull(nameof(predicate));
|
|
|
|
|
|
- return AnyCore(source, predicate, CancellationToken.None);
|
|
|
+ return AnyCore(source, cancellationToken);
|
|
|
}
|
|
|
|
|
|
- public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source)
|
|
|
+ public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
+ if (predicate == null)
|
|
|
+ throw Error.ArgumentNull(nameof(predicate));
|
|
|
|
|
|
- return AnyCore(source, CancellationToken.None);
|
|
|
+ return AnyCore(source, predicate, CancellationToken.None);
|
|
|
}
|
|
|
|
|
|
public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken cancellationToken)
|
|
@@ -48,22 +46,24 @@ namespace System.Linq
|
|
|
return AnyCore(source, predicate, cancellationToken);
|
|
|
}
|
|
|
|
|
|
- public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<bool>> predicate, CancellationToken cancellationToken)
|
|
|
+ public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<bool>> predicate)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
if (predicate == null)
|
|
|
throw Error.ArgumentNull(nameof(predicate));
|
|
|
|
|
|
- return AnyCore(source, predicate, cancellationToken);
|
|
|
+ return AnyCore(source, predicate, CancellationToken.None);
|
|
|
}
|
|
|
|
|
|
- public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken cancellationToken)
|
|
|
+ public static Task<bool> Any<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<bool>> predicate, CancellationToken cancellationToken)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
+ if (predicate == null)
|
|
|
+ throw Error.ArgumentNull(nameof(predicate));
|
|
|
|
|
|
- return AnyCore(source, cancellationToken);
|
|
|
+ return AnyCore(source, predicate, cancellationToken);
|
|
|
}
|
|
|
|
|
|
private static async Task<bool> AnyCore<TSource>(IAsyncEnumerable<TSource> source, CancellationToken cancellationToken)
|