From 74a538f6725ebc83efda4bb07d5747e8a6359e19 Mon Sep 17 00:00:00 2001 From: Atsushi Eno Date: Mon, 16 Dec 2013 22:30:03 +0900 Subject: Import Official Rx 2.2 (3ebdd2e09991) I made changes from the original source tree to match the older tree so that we don't have to make several changes to project tree generator. (There is actually no new sources in Rx so hopefully we can just reuse existing modifications in the tree). --- .../Reactive/Linq/Observable/TakeLastBuffer.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/TakeLastBuffer.cs') diff --git a/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/TakeLastBuffer.cs b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/TakeLastBuffer.cs index 71b36b0..2a15825 100644 --- a/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/TakeLastBuffer.cs +++ b/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/TakeLastBuffer.cs @@ -7,7 +7,7 @@ using System.Linq; using System.Reactive.Concurrency; using System.Reactive.Disposables; -namespace System.Reactive.Linq.Observαble +namespace System.Reactive.Linq.ObservableImpl { class TakeLastBuffer : Producer> { @@ -39,7 +39,7 @@ namespace System.Reactive.Linq.Observαble } else { - var sink = new τ(this, observer, cancel); + var sink = new Impl(this, observer, cancel); setSink(sink); return sink.Run(); } @@ -82,12 +82,12 @@ namespace System.Reactive.Linq.Observαble } } - class τ : Sink>, IObserver + class Impl : Sink>, IObserver { private readonly TakeLastBuffer _parent; private Queue> _queue; - public τ(TakeLastBuffer parent, IObserver> observer, IDisposable cancel) + public Impl(TakeLastBuffer parent, IObserver> observer, IDisposable cancel) : base(observer, cancel) { _parent = parent; -- cgit v1.2.3