From eae940a062bf0de07a0ac8132c62d49efa0fda0e Mon Sep 17 00:00:00 2001 From: akarnokd Date: Thu, 28 Jun 2018 15:29:44 +0200 Subject: [PATCH] 4.x: TakeLastBuffer() use base.Run, explicit args --- .../src/System.Reactive/Linq/Observable/TakeLastBuffer.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeLastBuffer.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeLastBuffer.cs index de6c572874..a217ef5fe6 100644 --- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeLastBuffer.cs +++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/TakeLastBuffer.cs @@ -70,7 +70,7 @@ public Time(IObservable source, TimeSpan duration, IScheduler scheduler protected override _ CreateSink(IObserver> observer) => new _(_duration, observer); - protected override void Run(_ sink) => sink.Run(this); + protected override void Run(_ sink) => sink.Run(_source, _scheduler); internal sealed class _ : Sink> { @@ -86,11 +86,11 @@ public _(TimeSpan duration, IObserver> observer) private IStopwatch _watch; - public void Run(Time parent) + public void Run(IObservable source, IScheduler scheduler) { - _watch = parent._scheduler.StartStopwatch(); + _watch = scheduler.StartStopwatch(); - SetUpstream(parent._source.SubscribeSafe(this)); + base.Run(source); } public override void OnNext(TSource value)