diff options
Diffstat (limited to 'Rx.NET/System.Reactive.Linq/Reactive/Internal/Sink.cs')
| -rw-r--r-- | Rx.NET/System.Reactive.Linq/Reactive/Internal/Sink.cs | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/Rx.NET/System.Reactive.Linq/Reactive/Internal/Sink.cs b/Rx.NET/System.Reactive.Linq/Reactive/Internal/Sink.cs deleted file mode 100644 index 4737504..0000000 --- a/Rx.NET/System.Reactive.Linq/Reactive/Internal/Sink.cs +++ /dev/null @@ -1,66 +0,0 @@ -#if !NO_PERF -using System.Threading; - -namespace System.Reactive -{ - /// <summary> - /// Base class for implementation of query operators, providing a lightweight sink that can be disposed to mute the outgoing observer. - /// </summary> - /// <typeparam name="TSource">Type of the resulting sequence's elements.</typeparam> - /// <remarks>Implementations of sinks are responsible to enforce the message grammar on the associated observer. Upon sending a terminal message, a pairing Dispose call should be made to trigger cancellation of related resources and to mute the outgoing observer.</remarks> - abstract class Sink<TSource> : IDisposable - { - protected volatile IObserver<TSource> _observer; - private IDisposable _cancel; - - public Sink(IObserver<TSource> observer, IDisposable cancel) - { - _observer = observer; - _cancel = cancel; - } - - public virtual void Dispose() - { - _observer = NopObserver<TSource>.Instance; - - var cancel = Interlocked.Exchange(ref _cancel, null); - if (cancel != null) - { - cancel.Dispose(); - } - } - - public IObserver<TSource> GetForwarder() - { - return new _(this); - } - - class _ : IObserver<TSource> - { - private readonly Sink<TSource> _forward; - - public _(Sink<TSource> forward) - { - _forward = forward; - } - - public void OnNext(TSource value) - { - _forward._observer.OnNext(value); - } - - public void OnError(Exception error) - { - _forward._observer.OnError(error); - _forward.Dispose(); - } - - public void OnCompleted() - { - _forward._observer.OnCompleted(); - _forward.Dispose(); - } - } - } -} -#endif
\ No newline at end of file |