diff options
Diffstat (limited to 'Rx.NET/System.Reactive.Core/Reactive/Internal/SynchronizedObserver.cs')
-rw-r--r-- | Rx.NET/System.Reactive.Core/Reactive/Internal/SynchronizedObserver.cs | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/Rx.NET/System.Reactive.Core/Reactive/Internal/SynchronizedObserver.cs b/Rx.NET/System.Reactive.Core/Reactive/Internal/SynchronizedObserver.cs deleted file mode 100644 index e41294e..0000000 --- a/Rx.NET/System.Reactive.Core/Reactive/Internal/SynchronizedObserver.cs +++ /dev/null @@ -1,40 +0,0 @@ -// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information. - -namespace System.Reactive -{ - internal class SynchronizedObserver<T> : ObserverBase<T> - { - private readonly object _gate; - private readonly IObserver<T> _observer; - - public SynchronizedObserver(IObserver<T> observer, object gate) - { - _gate = gate; - _observer = observer; - } - - protected override void OnNextCore(T value) - { - lock (_gate) - { - _observer.OnNext(value); - } - } - - protected override void OnErrorCore(Exception exception) - { - lock (_gate) - { - _observer.OnError(exception); - } - } - - protected override void OnCompletedCore() - { - lock (_gate) - { - _observer.OnCompleted(); - } - } - } -} |