// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System.Collections.Generic; using System.Linq.Expressions; using System.Reflection; namespace System.Linq { /// /// Provides a set of extension methods for asynchronous enumerable sequences represented using expression trees. /// public static partial class AsyncQueryable { /// /// Converts the specified asynchronous enumerable sequence to an expression representation. /// /// The type of the elements in the sequence. /// The asynchronous enumerable sequence to represent using an expression tree. /// An asynchronous enumerable sequence using an expression tree to represent the specified asynchronous enumerable sequence. public static IAsyncQueryable AsAsyncQueryable(this IAsyncEnumerable source) { if (source == null) throw new ArgumentNullException(nameof(source)); if (source is IAsyncQueryable queryable) { return queryable; } return new AsyncEnumerableQuery(source); } private static Expression GetSourceExpression(IAsyncEnumerable source) { if (source is IAsyncQueryable queryable) { return queryable.Expression; } return Expression.Constant(source, typeof(IAsyncEnumerable)); } internal static MethodInfo InfoOf(Expression> f) { return ((MethodCallExpression)f.Body).Method; } } }