diff options
Diffstat (limited to 'Rx.NET/System.Reactive.Core/Reactive/Internal/AsyncLockObserver.cs')
-rw-r--r-- | Rx.NET/System.Reactive.Core/Reactive/Internal/AsyncLockObserver.cs | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/Rx.NET/System.Reactive.Core/Reactive/Internal/AsyncLockObserver.cs b/Rx.NET/System.Reactive.Core/Reactive/Internal/AsyncLockObserver.cs deleted file mode 100644 index 7db2116..0000000 --- a/Rx.NET/System.Reactive.Core/Reactive/Internal/AsyncLockObserver.cs +++ /dev/null @@ -1,40 +0,0 @@ -using System.Reactive.Concurrency; - -namespace System.Reactive -{ - internal class AsyncLockObserver<T> : ObserverBase<T> - { - private readonly AsyncLock _gate; - private readonly IObserver<T> _observer; - - public AsyncLockObserver(IObserver<T> observer, AsyncLock gate) - { - _gate = gate; - _observer = observer; - } - - protected override void OnNextCore(T value) - { - _gate.Wait(() => - { - _observer.OnNext(value); - }); - } - - protected override void OnErrorCore(Exception exception) - { - _gate.Wait(() => - { - _observer.OnError(exception); - }); - } - - protected override void OnCompletedCore() - { - _gate.Wait(() => - { - _observer.OnCompleted(); - }); - } - } -} |