Use helper method to upcast classes

Author: hazzik

src/NHibernate/Engine/ISessionImplementor.cs

@@ -73,12 +73,8 @@ internal static void AutoFlushIfRequired(this ISessionImplementor implementor, I
 		/// <param name="queryParameters">The query parameters.</param>
 		public static IAsyncEnumerable<T> AsyncEnumerable<T>(this ISessionImplementor session, IQueryExpression query, QueryParameters queryParameters)
 		{
-			if (session is AbstractSessionImpl abstractSession)
-			{
-				return abstractSession.AsyncEnumerable<T>(query, queryParameters);
-			}
-
-			throw new NotImplementedException();
+			return ReflectHelper.CastOrThrow<AbstractSessionImpl>(session, "async enumerable")
+				.AsyncEnumerable<T>(query, queryParameters);
 		}
 
 		/// <summary>
@@ -91,12 +87,8 @@ public static IAsyncEnumerable<T> AsyncEnumerable<T>(this ISessionImplementor se
 		/// <param name="parameters">The query parameters.</param>
 		public static IAsyncEnumerable<T> AsyncEnumerableFilter<T>(this ISessionImplementor session, object collection, string filter, QueryParameters parameters)
 		{
-			if (session is AbstractSessionImpl abstractSession)
-			{
-				return abstractSession.AsyncEnumerableFilter<T>(collection, filter, parameters);
-			}
-
-			throw new NotImplementedException();
+			return ReflectHelper.CastOrThrow<AbstractSessionImpl>(session, "async enumerable")
+				.AsyncEnumerableFilter<T>(collection, filter, parameters);
 		}
 
 		/// <summary>

src/NHibernate/Hql/IQueryTranslator.cs

@@ -8,6 +8,7 @@
 using NHibernate.Event;
 using NHibernate.Hql.Ast.ANTLR;
 using NHibernate.Type;
+using NHibernate.Util;
 
 namespace NHibernate.Hql
 {
@@ -140,12 +141,8 @@ internal static class QueryTranslatorExtensions
 		/// <param name="session">The session.</param>
 		public static IAsyncEnumerable<T> GetAsyncEnumerable<T>(this IQueryTranslator queryTranslator, QueryParameters queryParameters, IEventSource session)
 		{
-			if (queryTranslator is QueryTranslatorImpl queryTranslatorImpl)
-			{
-				return queryTranslatorImpl.GetAsyncEnumerable<T>(queryParameters, session);
-			}
-
-			throw new NotImplementedException();
+			return ReflectHelper.CastOrThrow<QueryTranslatorImpl>(queryTranslator, "async enumerable")
+				.GetAsyncEnumerable<T>(queryParameters, session);
 		}
 	}
 }

src/NHibernate/IQuery.cs

@@ -6,6 +6,7 @@
 using NHibernate.Impl;
 using System.Threading.Tasks;
 using System.Threading;
+using NHibernate.Util;
 
 namespace NHibernate
 {
@@ -711,12 +712,7 @@ public static class QueryExtensions
 		/// <param name="query">The query.</param>
 		public static IAsyncEnumerable<T> AsyncEnumerable<T>(this IQuery query)
 		{
-			if (query is AbstractQueryImpl abstractQuery)
-			{
-				return abstractQuery.AsyncEnumerable<T>();
-			}
-
-			throw new NotImplementedException();
+			return ReflectHelper.CastOrThrow<AbstractQueryImpl>(query, "async enumerable").AsyncEnumerable<T>();
 		}
 	}
 }

src/NHibernate/Impl/AbstractSessionImpl.cs

@@ -661,7 +661,6 @@ internal IOuterJoinLoadable GetOuterJoinLoadable(string entityName)
 		[Obsolete("This method has no more usages and will be removed in a future version")]
 		public abstract Task<IEnumerable<T>> EnumerableAsync<T>(IQueryExpression queryExpression, QueryParameters queryParameters, CancellationToken cancellationToken);
 
-
 		// 6.0 TODO: make abstract
 		public virtual IAsyncEnumerable<T> AsyncEnumerable<T>(IQueryExpression queryExpression, QueryParameters queryParameters)
 		{

src/NHibernate/Linq/DefaultQueryProvider.cs

@@ -39,12 +39,8 @@ internal static class NhQueryProviderExtensions
 		/// <param name="expression">The query expression.</param>
 		public static IAsyncEnumerable<T> GetAsyncEnumerable<T>(this INhQueryProvider nhQueryProvider, Expression expression)
 		{
-			if (nhQueryProvider is DefaultQueryProvider defaultQueryProvider)
-			{
-				return defaultQueryProvider.GetAsyncEnumerable<T>(expression);
-			}
-
-			throw new NotImplementedException();
+			return ReflectHelper.CastOrThrow<DefaultQueryProvider>(nhQueryProvider, "async enumerable")
+				.GetAsyncEnumerable<T>(expression);
 		}
 	}