|
@@ -10,7 +10,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
|
|
|
/* The following code is generated by a T4 template. */
|
|
|
|
|
|
- #region CombineLatest auto-generated code (2018.05.28. 16:02:20)
|
|
|
+ #region CombineLatest auto-generated code (06.06.2018 11:24:41)
|
|
|
|
|
|
internal sealed class CombineLatest<T1, T2, T3, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, TResult>._>
|
|
|
{
|
|
@@ -27,16 +27,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(3, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(3, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -45,7 +45,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T2> _observer2;
|
|
|
private CombineLatestObserver<T3> _observer3;
|
|
|
|
|
|
- public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3)
|
|
|
+ public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[3];
|
|
|
for (int i = 0; i < 3; i++)
|
|
@@ -59,7 +59,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[1].Disposable = source2.SubscribeSafe(_observer2);
|
|
|
subscriptions[2].Disposable = source3.SubscribeSafe(_observer3);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value);
|
|
@@ -83,16 +83,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(4, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(4, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -102,7 +102,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T3> _observer3;
|
|
|
private CombineLatestObserver<T4> _observer4;
|
|
|
|
|
|
- public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4)
|
|
|
+ public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[4];
|
|
|
for (int i = 0; i < 4; i++)
|
|
@@ -118,7 +118,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[2].Disposable = source3.SubscribeSafe(_observer3);
|
|
|
subscriptions[3].Disposable = source4.SubscribeSafe(_observer4);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value);
|
|
@@ -144,16 +144,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(5, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(5, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -164,7 +164,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T4> _observer4;
|
|
|
private CombineLatestObserver<T5> _observer5;
|
|
|
|
|
|
- public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5)
|
|
|
+ public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[5];
|
|
|
for (int i = 0; i < 5; i++)
|
|
@@ -182,7 +182,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[3].Disposable = source4.SubscribeSafe(_observer4);
|
|
|
subscriptions[4].Disposable = source5.SubscribeSafe(_observer5);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value);
|
|
@@ -210,16 +210,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(6, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(6, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -231,7 +231,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T5> _observer5;
|
|
|
private CombineLatestObserver<T6> _observer6;
|
|
|
|
|
|
- public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6)
|
|
|
+ public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[6];
|
|
|
for (int i = 0; i < 6; i++)
|
|
@@ -251,7 +251,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[4].Disposable = source5.SubscribeSafe(_observer5);
|
|
|
subscriptions[5].Disposable = source6.SubscribeSafe(_observer6);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value);
|
|
@@ -281,16 +281,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(7, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(7, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -303,7 +303,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T6> _observer6;
|
|
|
private CombineLatestObserver<T7> _observer7;
|
|
|
|
|
|
- public IDisposable Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7)
|
|
|
+ public void Run(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[7];
|
|
|
for (int i = 0; i < 7; i++)
|
|
@@ -325,7 +325,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[5].Disposable = source6.SubscribeSafe(_observer6);
|
|
|
subscriptions[6].Disposable = source7.SubscribeSafe(_observer7);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value);
|
|
@@ -357,16 +357,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(8, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(8, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -380,7 +380,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T7> _observer7;
|
|
|
private CombineLatestObserver<T8> _observer8;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[8];
|
|
|
for (int i = 0; i < 8; i++)
|
|
@@ -404,7 +404,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[6].Disposable = source7.SubscribeSafe(_observer7);
|
|
|
subscriptions[7].Disposable = source8.SubscribeSafe(_observer8);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value, _observer8.Value);
|
|
@@ -438,16 +438,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(9, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(9, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -462,7 +462,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T8> _observer8;
|
|
|
private CombineLatestObserver<T9> _observer9;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[9];
|
|
|
for (int i = 0; i < 9; i++)
|
|
@@ -488,7 +488,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[7].Disposable = source8.SubscribeSafe(_observer8);
|
|
|
subscriptions[8].Disposable = source9.SubscribeSafe(_observer9);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value, _observer8.Value, _observer9.Value);
|
|
@@ -524,16 +524,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(10, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(10, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -549,7 +549,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T9> _observer9;
|
|
|
private CombineLatestObserver<T10> _observer10;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[10];
|
|
|
for (int i = 0; i < 10; i++)
|
|
@@ -577,7 +577,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[8].Disposable = source9.SubscribeSafe(_observer9);
|
|
|
subscriptions[9].Disposable = source10.SubscribeSafe(_observer10);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value, _observer8.Value, _observer9.Value, _observer10.Value);
|
|
@@ -615,16 +615,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(11, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(11, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -641,7 +641,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T10> _observer10;
|
|
|
private CombineLatestObserver<T11> _observer11;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[11];
|
|
|
for (int i = 0; i < 11; i++)
|
|
@@ -671,7 +671,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[9].Disposable = source10.SubscribeSafe(_observer10);
|
|
|
subscriptions[10].Disposable = source11.SubscribeSafe(_observer11);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _resultSelector(_observer1.Value, _observer2.Value, _observer3.Value, _observer4.Value, _observer5.Value, _observer6.Value, _observer7.Value, _observer8.Value, _observer9.Value, _observer10.Value, _observer11.Value);
|
|
@@ -711,16 +711,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(12, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(12, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -738,7 +738,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T11> _observer11;
|
|
|
private CombineLatestObserver<T12> _observer12;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[12];
|
|
|
for (int i = 0; i < 12; i++)
|
|
@@ -770,7 +770,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[10].Disposable = source11.SubscribeSafe(_observer11);
|
|
|
subscriptions[11].Disposable = source12.SubscribeSafe(_observer12);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _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);
|
|
@@ -812,16 +812,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(13, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(13, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -840,7 +840,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T12> _observer12;
|
|
|
private CombineLatestObserver<T13> _observer13;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[13];
|
|
|
for (int i = 0; i < 13; i++)
|
|
@@ -874,7 +874,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[11].Disposable = source12.SubscribeSafe(_observer12);
|
|
|
subscriptions[12].Disposable = source13.SubscribeSafe(_observer13);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _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);
|
|
@@ -918,16 +918,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> _resultSelector;
|
|
|
|
|
|
- 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)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(14, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -947,7 +947,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T13> _observer13;
|
|
|
private CombineLatestObserver<T14> _observer14;
|
|
|
|
|
|
- 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)
|
|
|
+ public void 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)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[14];
|
|
|
for (int i = 0; i < 14; i++)
|
|
@@ -983,7 +983,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[12].Disposable = source13.SubscribeSafe(_observer13);
|
|
|
subscriptions[13].Disposable = source14.SubscribeSafe(_observer14);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _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);
|
|
@@ -1029,16 +1029,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(15, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(15, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -1059,7 +1059,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T14> _observer14;
|
|
|
private CombineLatestObserver<T15> _observer15;
|
|
|
|
|
|
- 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, IObservable<T15> source15)
|
|
|
+ public void 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, IObservable<T15> source15)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[15];
|
|
|
for (int i = 0; i < 15; i++)
|
|
@@ -1097,7 +1097,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[13].Disposable = source14.SubscribeSafe(_observer14);
|
|
|
subscriptions[14].Disposable = source15.SubscribeSafe(_observer15);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _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, _observer15.Value);
|
|
@@ -1145,16 +1145,16 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer) => new _(_resultSelector, observer);
|
|
|
|
|
|
- protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15, _source16);
|
|
|
+ protected override void Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15, _source16);
|
|
|
|
|
|
internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> _resultSelector;
|
|
|
|
|
|
- public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> resultSelector, IObserver<TResult> observer, IDisposable cancel)
|
|
|
- : base(16, observer, cancel)
|
|
|
+ public _(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> resultSelector, IObserver<TResult> observer)
|
|
|
+ : base(16, observer)
|
|
|
{
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
@@ -1176,7 +1176,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
private CombineLatestObserver<T15> _observer15;
|
|
|
private CombineLatestObserver<T16> _observer16;
|
|
|
|
|
|
- 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, IObservable<T15> source15, IObservable<T16> source16)
|
|
|
+ public void 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, IObservable<T15> source15, IObservable<T16> source16)
|
|
|
{
|
|
|
var subscriptions = new SingleAssignmentDisposable[16];
|
|
|
for (int i = 0; i < 16; i++)
|
|
@@ -1216,7 +1216,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
subscriptions[14].Disposable = source15.SubscribeSafe(_observer15);
|
|
|
subscriptions[15].Disposable = source16.SubscribeSafe(_observer16);
|
|
|
|
|
|
- return StableCompositeDisposable.Create(subscriptions);
|
|
|
+ SetUpstream(StableCompositeDisposable.Create(subscriptions));
|
|
|
}
|
|
|
|
|
|
protected override TResult GetResult() => _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, _observer15.Value, _observer16.Value);
|