Enum SubscriberNotification 

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

SubscriberNotification

Represents all signals a subscriber can observe in a materialized form

• Can be pushed into Subscribers to trigger a call.
• Can be converted from ObserverNotification
• Can be converted from ObserverTerminalNotification
• Can be converted from SubscriptionNotification
• Can try to convert into a ObserverNotification
• Can try to convert into a ObserverTerminalNotification
• Can try to convert into a SubscriptionNotification

Variants

Next(In)

Error(InError)

Complete

Unsubscribe

Implementations

impl<In, InError> SubscriberNotification<In, InError>

where In: Signal, InError: Signal,

pub fn is_terminal(&self) -> bool

pub fn is_closing(&self) -> bool

Trait Implementations

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

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

fn clone(&self) -> SubscriberNotification<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 SubscriberNotification<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 SubscriberNotification<In, InError>

where In: Signal, InError: Signal,

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

Converts to this type from the input type.

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

where In: Signal, InError: Signal,

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

Converts to this type from the input type.

impl<In, InError> Hash for SubscriberNotification<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 SubscriberNotification<In, InError>

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

fn cmp(&self, other: &SubscriberNotification<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 SubscriberNotification<In, InError>

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

fn eq(&self, other: &SubscriberNotification<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 SubscriberNotification<In, InError>

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

fn partial_cmp( &self, other: &SubscriberNotification<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<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> TryFrom<SubscriberNotification<In, InError>> for ObserverTerminalNotification<InError>

where In: Signal, InError: Signal,

type Error = SubscriberToObserverTerminalNotificationConversionError

The type returned in the event of a conversion error.

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

Performs the conversion.

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

where In: Signal, InError: Signal,

type Error = SubscriberToSubscriptionNotificationConversionError

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

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

where In: Signal, InError: Signal,