|
@@ -10,9 +10,9 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
|
|
|
/* The following code is generated by a T4 template. */
|
|
|
|
|
|
- #region CombineLatest auto-generated code (4/17/2017 3:25:27 PM)
|
|
|
+ #region CombineLatest auto-generated code (4/20/2017 3:38:14 PM)
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -27,14 +27,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, TResult> _resultSelector;
|
|
|
|
|
@@ -69,7 +66,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -86,14 +83,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, TResult> _resultSelector;
|
|
|
|
|
@@ -131,7 +125,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -150,14 +144,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, TResult> _resultSelector;
|
|
|
|
|
@@ -198,7 +189,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -219,14 +210,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ protected override IDisposable 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;
|
|
|
|
|
@@ -270,7 +258,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -293,14 +281,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ protected override IDisposable 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;
|
|
|
|
|
@@ -347,7 +332,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -372,14 +357,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> _resultSelector;
|
|
|
|
|
@@ -429,7 +411,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -456,14 +438,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> _resultSelector;
|
|
|
|
|
@@ -516,7 +495,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -545,14 +524,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> _resultSelector;
|
|
|
|
|
@@ -608,7 +584,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -639,14 +615,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> _resultSelector;
|
|
|
|
|
@@ -705,7 +678,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -738,14 +711,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> _resultSelector;
|
|
|
|
|
@@ -807,7 +777,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -842,14 +812,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ protected override IDisposable 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;
|
|
|
|
|
@@ -914,7 +881,7 @@ 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>
|
|
|
+ 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>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -951,14 +918,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ protected override IDisposable 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;
|
|
|
|
|
@@ -1026,7 +990,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -1065,14 +1029,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ 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;
|
|
|
|
|
@@ -1143,7 +1104,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> : Producer<TResult>
|
|
|
+ internal sealed class CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> : Producer<TResult, CombineLatest<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>._>
|
|
|
{
|
|
|
private readonly IObservable<T1> _source1;
|
|
|
private readonly IObservable<T2> _source2;
|
|
@@ -1184,14 +1145,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink)
|
|
|
- {
|
|
|
- var sink = new _(_resultSelector, observer, cancel);
|
|
|
- setSink(sink);
|
|
|
- return sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15, _source16);
|
|
|
- }
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+
|
|
|
+ protected override IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14, _source15, _source16);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ 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;
|
|
|
|