ConnectableObservable<TSource, TResult> sealed class ConnectableObservable<TSource, TResult> : IConnectableObservable<TResult>, IObservable<TResult> Documentation Code public ConnectableObservable(IObservable<TSource> source, ISubject<TSource, TResult> subject) public IDisposable Connect() public IDisposable Subscribe(IObserver<TResult> observer)