ISubject<TSource, TResult> public interface ISubject<TSource, TResult> : IObserver<TSource>, IObservable<TResult> Documentation Code