using System.Runtime.CompilerServices; namespace System.Reactive.Joins { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(0)] public class Pattern<[System.Runtime.CompilerServices.Nullable(2)] TSource1, [System.Runtime.CompilerServices.Nullable(2)] TSource2, [System.Runtime.CompilerServices.Nullable(2)] TSource3, [System.Runtime.CompilerServices.Nullable(2)] TSource4> : Pattern { internal IObservable<TSource1> First { get; } internal IObservable<TSource2> Second { get; } internal IObservable<TSource3> Third { get; } internal IObservable<TSource4> Fourth { get; } internal Pattern(IObservable<TSource1> first, IObservable<TSource2> second, IObservable<TSource3> third, IObservable<TSource4> fourth) { First = first; Second = second; Third = third; Fourth = fourth; } public Pattern<TSource1, TSource2, TSource3, TSource4, TSource5> And<[System.Runtime.CompilerServices.Nullable(2)] TSource5>(IObservable<TSource5> other) { if (other == null) throw new ArgumentNullException("other"); return new Pattern<TSource1, TSource2, TSource3, TSource4, TSource5>(this.First, this.Second, this.Third, this.Fourth, other); } public Plan<TResult> Then<[System.Runtime.CompilerServices.Nullable(2)] TResult>(Func<TSource1, TSource2, TSource3, TSource4, TResult> selector) { if (selector == null) throw new ArgumentNullException("selector"); return new System.Reactive.Joins.Plan<TSource1, TSource2, TSource3, TSource4, TResult>(this, selector); } } }