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, 28 insertions, 0 deletions
diff --git a/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs b/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs new file mode 100644 index 0000000..568bc02 --- /dev/null +++ b/Rx.NET/Tests.System.Reactive/Tests/ConnectableObservable.cs @@ -0,0 +1,28 @@ +// 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); + } + } +} |