We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 73e86bf commit 07a69aeCopy full SHA for 07a69ae
src/NHibernate/Engine/Query/HQLQueryPlan.cs
@@ -41,12 +41,8 @@ internal static class QueryPlanExtensions
41
/// <param name="session">The session.</param>
42
public static IAsyncEnumerable<T> PerformAsyncIterate<T>(this IQueryPlan queryPlan, QueryParameters queryParameters, IEventSource session)
43
{
44
- if (queryPlan is HQLQueryPlan hQLQueryPlan)
45
- {
46
- return hQLQueryPlan.PerformAsyncIterate<T>(queryParameters, session);
47
- }
48
-
49
- throw new NotImplementedException();
+ return ReflectHelper.CastOrThrow<HQLQueryPlan>(queryPlan, "async enumerable")
+ .PerformAsyncIterate<T>(queryParameters, session);
50
}
51
52
0 commit comments