using System.Linq.Expressions; using System.Reactive.Linq; using System.Reflection; using System.Runtime.CompilerServices; namespace System.Reactive.Joins { [System.Runtime.CompilerServices.NullableContext(2)] [System.Runtime.CompilerServices.Nullable(0)] public class QueryablePattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10> : QueryablePattern { [System.Runtime.CompilerServices.NullableContext(1)] internal QueryablePattern(Expression expression) : base(expression) { } [System.Runtime.CompilerServices.NullableContext(1)] public QueryablePattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11> And<[System.Runtime.CompilerServices.Nullable(2)] TSource11>(IObservable<TSource11> other) { if (other == null) throw new ArgumentNullException("other"); MethodInfo method = typeof(QueryablePattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10>).GetMethod("And").MakeGenericMethod(typeof(TSource11)); return new QueryablePattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11>((Expression)Expression.Call(base.Expression, method, Qbservable.GetSourceExpression<TSource11>(other))); } [System.Runtime.CompilerServices.NullableContext(1)] public QueryablePlan<TResult> Then<[System.Runtime.CompilerServices.Nullable(2)] TResult>(Expression<Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>> selector) { if (selector == null) throw new ArgumentNullException("selector"); MethodInfo method = typeof(QueryablePattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10>).GetMethod("Then").MakeGenericMethod(typeof(TResult)); return new QueryablePlan<TResult>((Expression)Expression.Call(base.Expression, method, selector)); } } }