diff options
Diffstat (limited to 'Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs')
-rw-r--r-- | Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs b/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs deleted file mode 100644 index 568bc02..0000000 --- a/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs +++ /dev/null @@ -1,28 +0,0 @@ -// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information. - -using System; -using System.Reactive.Linq; -using System.Reactive.Subjects; - -namespace ReactiveTests.Tests -{ - class ConnectableObservable<T> : IConnectableObservable<T> - { - private IConnectableObservable<T> _o; - - public ConnectableObservable(IObservable<T> o, ISubject<T, T> s) - { - _o = o.Multicast(s); - } - - public IDisposable Connect() - { - return _o.Connect(); - } - - public IDisposable Subscribe(IObserver<T> observer) - { - return _o.Subscribe(observer); - } - } -} |