AsyncSubject<T> public sealed class AsyncSubject<T> : SubjectBase<T>, IDisposable, INotifyCompletion Documentation Code public bool IsCompleted { get; } public AsyncSubject() public AsyncSubject<T> GetAwaiter() public T GetResult() public void OnCompleted(Action continuation)