CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>
sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> : Producer<TResult, _<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>>
using System.Reactive.Disposables;
namespace System.Reactive.Linq.ObservableImpl
{
internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>._>
{
internal sealed class _ : CombineLatestSink<TResult>
{
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> _resultSelector;
private CombineLatestObserver<T1> _observer1;
private CombineLatestObserver<T2> _observer2;
private CombineLatestObserver<T3> _observer3;
private CombineLatestObserver<T4> _observer4;
private CombineLatestObserver<T5> _observer5;
private CombineLatestObserver<T6> _observer6;
private CombineLatestObserver<T7> _observer7;
private CombineLatestObserver<T8> _observer8;
private CombineLatestObserver<T9> _observer9;
private CombineLatestObserver<T10> _observer10;
private CombineLatestObserver<T11> _observer11;
private CombineLatestObserver<T12> _observer12;
private CombineLatestObserver<T13> _observer13;
private CombineLatestObserver<T14> _observer14;
public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
: base(14, observer, cancel)
{
_resultSelector = resultSelector;
}
public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14)
{
SingleAssignmentDisposable[] array = new SingleAssignmentDisposable[14];
for (int i = 0; i < 14; i++) {
array[i] = new SingleAssignmentDisposable();
}
_observer1 = new CombineLatestObserver<T1>(_gate, this, 0, array[0]);
_observer2 = new CombineLatestObserver<T2>(_gate, this, 1, array[1]);
_observer3 = new CombineLatestObserver<T3>(_gate, this, 2, array[2]);
_observer4 = new CombineLatestObserver<T4>(_gate, this, 3, array[3]);
_observer5 = new CombineLatestObserver<T5>(_gate, this, 4, array[4]);
_observer6 = new CombineLatestObserver<T6>(_gate, this, 5, array[5]);
_observer7 = new CombineLatestObserver<T7>(_gate, this, 6, array[6]);
_observer8 = new CombineLatestObserver<T8>(_gate, this, 7, array[7]);
_observer9 = new CombineLatestObserver<T9>(_gate, this, 8, array[8]);
_observer10 = new CombineLatestObserver<T10>(_gate, this, 9, array[9]);
_observer11 = new CombineLatestObserver<T11>(_gate, this, 10, array[10]);
_observer12 = new CombineLatestObserver<T12>(_gate, this, 11, array[11]);
_observer13 = new CombineLatestObserver<T13>(_gate, this, 12, array[12]);
_observer14 = new CombineLatestObserver<T14>(_gate, this, 13, array[13]);
array[0].Disposable = ObservableExtensions.SubscribeSafe<T1>(source1, (IObserver<T1>)_observer1);
array[1].Disposable = ObservableExtensions.SubscribeSafe<T2>(source2, (IObserver<T2>)_observer2);
array[2].Disposable = ObservableExtensions.SubscribeSafe<T3>(source3, (IObserver<T3>)_observer3);
array[3].Disposable = ObservableExtensions.SubscribeSafe<T4>(source4, (IObserver<T4>)_observer4);
array[4].Disposable = ObservableExtensions.SubscribeSafe<T5>(source5, (IObserver<T5>)_observer5);
array[5].Disposable = ObservableExtensions.SubscribeSafe<T6>(source6, (IObserver<T6>)_observer6);
array[6].Disposable = ObservableExtensions.SubscribeSafe<T7>(source7, (IObserver<T7>)_observer7);
array[7].Disposable = ObservableExtensions.SubscribeSafe<T8>(source8, (IObserver<T8>)_observer8);
array[8].Disposable = ObservableExtensions.SubscribeSafe<T9>(source9, (IObserver<T9>)_observer9);
array[9].Disposable = ObservableExtensions.SubscribeSafe<T10>(source10, (IObserver<T10>)_observer10);
array[10].Disposable = ObservableExtensions.SubscribeSafe<T11>(source11, (IObserver<T11>)_observer11);
array[11].Disposable = ObservableExtensions.SubscribeSafe<T12>(source12, (IObserver<T12>)_observer12);
array[12].Disposable = ObservableExtensions.SubscribeSafe<T13>(source13, (IObserver<T13>)_observer13);
array[13].Disposable = ObservableExtensions.SubscribeSafe<T14>(source14, (IObserver<T14>)_observer14);
IDisposable[] disposables = array;
return StableCompositeDisposable.Create(disposables);
}
protected override TResult GetResult()
{
return _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value, _observer8.Value, _observer9.Value, _observer10.Value, _observer11.Value, _observer12.Value, _observer13.Value, _observer14.Value);
}
}
private readonly IObservable<T1> _source1;
private readonly IObservable<T2> _source2;
private readonly IObservable<T3> _source3;
private readonly IObservable<T4> _source4;
private readonly IObservable<T5> _source5;
private readonly IObservable<T6> _source6;
private readonly IObservable<T7> _source7;
private readonly IObservable<T8> _source8;
private readonly IObservable<T9> _source9;
private readonly IObservable<T10> _source10;
private readonly IObservable<T11> _source11;
private readonly IObservable<T12> _source12;
private readonly IObservable<T13> _source13;
private readonly IObservable<T14> _source14;
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> _resultSelector;
public CombineLatest(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> resultSelector)
{
_source1 = source1;
_source2 = source2;
_source3 = source3;
_source4 = source4;
_source5 = source5;
_source6 = source6;
_source7 = source7;
_source8 = source8;
_source9 = source9;
_source10 = source10;
_source11 = source11;
_source12 = source12;
_source13 = source13;
_source14 = source14;
_resultSelector = resultSelector;
}
protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel)
{
return new _(_resultSelector, observer, cancel);
}
protected override IDisposable Run(_ sink)
{
return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14);
}
}
}