Enum ObserverNotification 

pub enum ObserverNotification<In, InError = Infallible>
where
    In: Signal,
    InError: Signal,
{
    Next(In),
    Error(InError),
    Complete,
}

ObserverNotification

Represents all signals a observer can observe in a materialized form

• Can be pushed into [Observer]s and [Subscribers] to trigger a call.
• Can try to be converted into a ObserverTerminalNotification
  • Will fail for Next
• Can be converted into SubscriberNotification
• Can try to convert from a SubscriberNotification

Variants

Next(In)

Error(InError)

Complete

Trait Implementations

impl<In, InError> Clone for ObserverNotification<In, InError>

where In: Clone + Signal, InError: Clone + Signal,

fn clone(&self) -> ObserverNotification<In, InError>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<In, InError> Debug for ObserverNotification<In, InError>

where In: Debug + Signal, InError: Debug + Signal,

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

Formats the value using the given formatter.

impl<In, InError> From<ObserverNotification<In, InError>> for SubscriberNotification<In, InError>

where In: Signal, InError: Signal,

fn from( value: ObserverNotification<In, InError>, ) -> SubscriberNotification<In, InError>

Converts to this type from the input type.

impl<In, InError> From<ObserverTerminalNotification<InError>> for ObserverNotification<In, InError>

where In: Signal, InError: Signal,

fn from( value: ObserverTerminalNotification<InError>, ) -> ObserverNotification<In, InError>

Converts to this type from the input type.

impl<In, InError> Hash for ObserverNotification<In, InError>

where In: Hash + Signal, InError: Hash + Signal,

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

where __H: Hasher,

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<In, InError> Ord for ObserverNotification<In, InError>

where In: Ord + Signal, InError: Ord + Signal,

fn cmp(&self, other: &ObserverNotification<In, InError>) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl<In, InError> PartialEq for ObserverNotification<In, InError>

where In: PartialEq + Signal, InError: PartialEq + Signal,

fn eq(&self, other: &ObserverNotification<In, InError>) -> bool

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<In, InError> PartialOrd for ObserverNotification<In, InError>

where In: PartialOrd + Signal, InError: PartialOrd + Signal,

fn partial_cmp( &self, other: &ObserverNotification<In, InError>, ) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl<In, InError> TryFrom<ObserverNotification<In, InError>> for ObserverTerminalNotification<InError>

where In: Signal, InError: Signal,

type Error = ObserverToObserverTerminalNotificationConversionError

The type returned in the event of a conversion error.

fn try_from( value: ObserverNotification<In, InError>, ) -> Result<ObserverTerminalNotification<InError>, <ObserverTerminalNotification<InError> as TryFrom<ObserverNotification<In, InError>>>::Error>

Performs the conversion.

impl<In, InError> TryFrom<SubscriberNotification<In, InError>> for ObserverNotification<In, InError>

where In: Signal, InError: Signal,

type Error = SubscriberToObserverNotificationConversionError

The type returned in the event of a conversion error.

fn try_from( value: SubscriberNotification<In, InError>, ) -> Result<ObserverNotification<In, InError>, <ObserverNotification<In, InError> as TryFrom<SubscriberNotification<In, InError>>>::Error>

Performs the conversion.

impl<In, InError> Eq for ObserverNotification<In, InError>

where In: Eq + Signal, InError: Eq + Signal,

impl<In, InError> StructuralPartialEq for ObserverNotification<In, InError>

where In: Signal, InError: Signal,