diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/CombineLatest.Generated.tt b/Rx.NET/Source/src/System.Reactive/Linq/Observable/CombineLatest.Generated.tt index 5b9568e6da..51aa934074 100644 --- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/CombineLatest.Generated.tt +++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/CombineLatest.Generated.tt @@ -51,7 +51,7 @@ for (var j = 1; j <= i; j++) _resultSelector = resultSelector; } - protected override _ CreateSink2(IObserver observer, IDisposable cancel) => new _(_resultSelector, observer, cancel); + protected override _ CreateSink(IObserver observer, IDisposable cancel) => new _(_resultSelector, observer, cancel); protected override IDisposable Run(_ sink) => sink.Run(<#=ss#>); diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.Generated.tt b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.Generated.tt index b03c5dce62..846eb1cfa4 100644 --- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.Generated.tt +++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.Generated.tt @@ -51,7 +51,7 @@ for (var j = 1; j <= i; j++) _resultSelector = resultSelector; } - protected override _ CreateSink2(IObserver observer, IDisposable cancel) => new _(_resultSelector, observer, cancel); + protected override _ CreateSink(IObserver observer, IDisposable cancel) => new _(_resultSelector, observer, cancel); protected override IDisposable Run(_ sink) => sink.Run(<#=ss#>);