using System.Reactive.Disposables; namespace System.Reactive.Linq.ObservableImpl { internal sealed class Zip<T1, T2, T3, T4, T5, T6, TResult> : Producer<TResult, Zip<T1, T2, T3, T4, T5, T6, TResult>._> { internal sealed class _ : ZipSink<TResult> { private readonly Func<T1, T2, T3, T4, T5, T6, TResult> _resultSelector; private ZipObserver<T1> _observer1; private ZipObserver<T2> _observer2; private ZipObserver<T3> _observer3; private ZipObserver<T4> _observer4; private ZipObserver<T5> _observer5; private ZipObserver<T6> _observer6; public _(Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector, IObserver<TResult> observer) : base(6, observer) { _resultSelector = resultSelector; } public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6) { IDisposable[] array = new IDisposable[6]; _observer1 = new ZipObserver<T1>(_gate, this, 0); array[0] = _observer1; base.Queues[0] = _observer1.Values; _observer2 = new ZipObserver<T2>(_gate, this, 1); array[1] = _observer2; base.Queues[1] = _observer2.Values; _observer3 = new ZipObserver<T3>(_gate, this, 2); array[2] = _observer3; base.Queues[2] = _observer3.Values; _observer4 = new ZipObserver<T4>(_gate, this, 3); array[3] = _observer4; base.Queues[3] = _observer4.Values; _observer5 = new ZipObserver<T5>(_gate, this, 4); array[4] = _observer5; base.Queues[4] = _observer5.Values; _observer6 = new ZipObserver<T6>(_gate, this, 5); array[5] = _observer6; base.Queues[5] = _observer6.Values; _observer1.SetResource(ObservableExtensions.SubscribeSafe<T1>(source1, (IObserver<T1>)_observer1)); _observer2.SetResource(ObservableExtensions.SubscribeSafe<T2>(source2, (IObserver<T2>)_observer2)); _observer3.SetResource(ObservableExtensions.SubscribeSafe<T3>(source3, (IObserver<T3>)_observer3)); _observer4.SetResource(ObservableExtensions.SubscribeSafe<T4>(source4, (IObserver<T4>)_observer4)); _observer5.SetResource(ObservableExtensions.SubscribeSafe<T5>(source5, (IObserver<T5>)_observer5)); _observer6.SetResource(ObservableExtensions.SubscribeSafe<T6>(source6, (IObserver<T6>)_observer6)); SetUpstream(StableCompositeDisposable.CreateTrusted(array)); } protected override TResult GetResult() { return _resultSelector(_observer1.Values.Dequeue(), _observer2.Values.Dequeue(), _observer3.Values.Dequeue(), _observer4.Values.Dequeue(), _observer5.Values.Dequeue(), _observer6.Values.Dequeue()); } } 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 Func<T1, T2, T3, T4, T5, T6, TResult> _resultSelector; public Zip(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector) { _source1 = source1; _source2 = source2; _source3 = source3; _source4 = source4; _source5 = source5; _source6 = source6; _resultSelector = resultSelector; } protected override _ CreateSink(IObserver<TResult> observer) { return new _(_resultSelector, observer); } protected override void Run(_ sink) { sink.Run(_source1, _source2, _source3, _source4, _source5, _source6); } } }