AnonymousSafeObserver<T> sealed class AnonymousSafeObserver<T> : IObserver<T> Documentation Code public AnonymousSafeObserver(Action<T> onNext, Action<Exception> onError, Action onCompleted, IDisposable disposable) public void OnCompleted() public void OnError(Exception error) public void OnNext(T value)