System.Reactive.AnonymousObserver<T>

public sealed class AnonymousObserver<T> : ObserverBase<T>

Class to create an IObserver<T> instance from delegate-based implementations of the On* methods.

public AnonymousObserver(Action<T> onNext, Action<Exception> onError, Action onCompleted)

Creates an observer from the specified OnNext, OnError, and OnCompleted actions.

Creates an observer from the specified OnNext action.

Creates an observer from the specified OnNext and OnError actions.

public AnonymousObserver(Action<T> onNext, Action onCompleted)

Creates an observer from the specified OnNext and OnCompleted actions.