SafeObserver<TSource> sealed class SafeObserver<TSource> : IObserver<TSource> Documentation Code public static IObserver<TSource> Create(IObserver<TSource> observer, IDisposable disposable) public void OnCompleted() public void OnError(Exception error) public void OnNext(TSource value)