Enum Notification 

pub enum Notification<T> {
    OnNext(T),
    OnError(ObservableError),
    OnCompleted,
}

A notification of an observable sequence as a value (Notification<T>).

Two notifications are equal when they are of the same kind and their values are equal; errors compare by identity, as exceptions do upstream.

Variants

OnNext(T)

A value (Notification.CreateOnNext).

OnError(ObservableError)

An error (Notification.CreateOnError).

OnCompleted

The end of the sequence (Notification.CreateOnCompleted).

Implementations

impl<T> Notification<T>

pub fn kind(&self) -> NotificationKind

The kind of the notification (Kind).

pub fn has_value(&self) -> bool

Whether the notification has a value (HasValue).

pub fn value(&self) -> Option<&T>

The value of an OnNext notification (Value); None for the others, where upstream throws the error of an OnError and InvalidOperationException for OnCompleted.

pub fn exception(&self) -> Option<&ObservableError>

The error of an OnError notification (Exception).

pub fn accept(self, observer: &dyn IObserver<T>)

Delivers the notification to an observer (Accept(IObserver<T>)).

pub fn accept_observer_with_result<R>( self, observer: &dyn IObserverWithResult<T, R>, ) -> R

Delivers the notification to an observer whose handlers return a result, and returns it (Accept<TResult>(IObserver<T, TResult>)).

pub fn accept_fns<R>( self, on_next: impl FnOnce(T) -> R, on_error: impl FnOnce(ObservableError) -> R, on_completed: impl FnOnce() -> R, ) -> R

Calls the function for the kind of the notification (Accept(Func<T, TResult>, ...)).

impl<T: Clone + 'static> Notification<T>

pub fn to_observable(&self) -> Rc<dyn IObservable<T>>

A sequence of the one notification, delivered on the immediate scheduler (ToObservable()).

pub fn to_observable_on( &self, scheduler: Rc<dyn IScheduler>, ) -> Rc<dyn IObservable<T>>

A sequence of the one notification, delivered on scheduler: a value is followed by the end of the sequence (ToObservable(IScheduler)).

Trait Implementations

impl<T: Clone> Clone for Notification<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Notification<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Hash> Hash for Notification<T>

The hash of a notification (GetHashCode), consistent with its equality: a value hashes as the value; an error by its identity (the address of the error, which is what its equality compares); the end of the sequence as the name of the type of the values combined with a constant, as upstream’s typeof(T).FullName.GetHashCode() ^ 8510.

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<T: 'static> NotificationValue for Notification<T>

type Value = T

The type of the values of the notification.

fn into_notification(self) -> Notification<T>

The notification.

impl<T: PartialEq> PartialEq for Notification<T>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.