<PackageReference Include="System.Reactive" Version="4.3.1" />

Notification<T>

public abstract class Notification<T> : IEquatable<Notification<T>>
Represents a notification to an observer.
public abstract Exception Exception { get; }

Returns the exception of an OnError notification or returns null.

public abstract bool HasValue { get; }

Returns a value that indicates whether the notification has a value.

public abstract NotificationKind Kind { get; }

Gets the kind of notification that is represented.

public abstract T Value { get; }

Returns the value of an OnNext notification or throws an exception.

public static bool op_Equality(Notification<T> left, Notification<T> right)

Determines whether the two specified Notification<T> objects have the same observer message payload.

public static bool op_Inequality(Notification<T> left, Notification<T> right)

Determines whether the two specified Notification<T> objects have a different observer message payload.

public abstract void Accept(IObserver<T> observer)

Invokes the observer's method corresponding to the notification.

public abstract TResult Accept<TResult>(IObserver<T, TResult> observer)

Invokes the observer's method corresponding to the notification and returns the produced result.

public abstract void Accept(Action<T> onNext, Action<Exception> onError, Action onCompleted)

Invokes the delegate corresponding to the notification.

public abstract TResult Accept<TResult>(Func<T, TResult> onNext, Func<Exception, TResult> onError, Func<TResult> onCompleted)

Invokes the delegate corresponding to the notification and returns the produced result.

public abstract bool Equals(Notification<T> other)

Determines whether the current Notification<T> object has the same observer message payload as a specified Notification<T> value.

Returns an observable sequence with a single notification, using the immediate scheduler.

public IObservable<T> ToObservable(IScheduler scheduler)

Returns an observable sequence with a single notification.