|
|
@@ -10,9 +10,9 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
|
|
|
/* The following code is generated by a T4 template. */
|
|
|
|
|
|
- #region CombineLatest auto-generated code (4/20/2017 2:55:11 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,16 +27,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -71,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;
|
|
|
@@ -88,16 +83,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -135,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;
|
|
|
@@ -154,16 +144,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -204,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;
|
|
|
@@ -225,16 +210,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, TResult> _resultSelector;
|
|
|
|
|
|
@@ -278,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;
|
|
|
@@ -301,16 +281,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7);
|
|
|
|
|
|
- private sealed class _ : CombineLatestSink<TResult>
|
|
|
+ internal sealed class _ : CombineLatestSink<TResult>
|
|
|
{
|
|
|
private readonly Func<T1, T2, T3, T4, T5, T6, T7, TResult> _resultSelector;
|
|
|
|
|
|
@@ -357,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;
|
|
|
@@ -382,16 +357,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -441,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;
|
|
|
@@ -468,16 +438,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -530,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;
|
|
|
@@ -559,16 +524,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -624,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;
|
|
|
@@ -655,16 +615,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -723,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;
|
|
|
@@ -756,16 +711,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -827,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;
|
|
|
@@ -862,16 +812,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13);
|
|
|
|
|
|
- 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, TResult> _resultSelector;
|
|
|
|
|
|
@@ -936,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;
|
|
|
@@ -973,16 +918,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 IDisposable Run(_ sink) => sink.Run(_source1, _source2, _source3, _source4, _source5, _source6, _source7, _source8, _source9, _source10, _source11, _source12, _source13, _source14);
|
|
|
|
|
|
- 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, TResult> _resultSelector;
|
|
|
|
|
|
@@ -1050,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;
|
|
|
@@ -1089,16 +1029,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|
|
|
@@ -1169,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;
|
|
|
@@ -1210,16 +1145,11 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
_resultSelector = resultSelector;
|
|
|
}
|
|
|
|
|
|
- protected override IDisposable CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
+ protected override _ CreateSink(IObserver<TResult> observer, IDisposable cancel) => new _(_resultSelector, observer, cancel);
|
|
|
|
|
|
- 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 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;
|
|
|
|