Enum SocketUpdate 

pub enum SocketUpdate<Sink, T> {
    Connected(Sink),
    Reconnecting,
    Item(T),
}

Socket lifecycle events wrapping stream items.

Variants

Connected(Sink)

Socket connected, providing the sink for sending data.

Reconnecting

Socket disconnected, reconnection in progress.

Item(T)

Data item received from the socket.

Implementations

impl<Sink, T> SocketUpdate<Sink, T>

pub fn map<F, O>(self, op: F) -> SocketUpdate<Sink, O>

where F: FnOnce(T) -> O,

Maps the item using the provided function.

impl<Sink, T, E> SocketUpdate<Sink, Result<T, E>>

pub fn map_ok<F, O>(self, op: F) -> SocketUpdate<Sink, Result<O, E>>

where F: FnOnce(T) -> O,

Maps the Ok value of a Result item.

pub fn map_err<F, O>(self, op: F) -> SocketUpdate<Sink, Result<T, O>>

where F: FnOnce(E) -> O,

Maps the Err value of a Result item.

Trait Implementations

impl<Sink: Clone, T: Clone> Clone for SocketUpdate<Sink, T>

fn clone(&self) -> SocketUpdate<Sink, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Sink: Debug, T: Debug> Debug for SocketUpdate<Sink, T>

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

Formats the value using the given formatter.

impl<'de, Sink, T> Deserialize<'de> for SocketUpdate<Sink, T>

where Sink: Deserialize<'de>, T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Sink, T> From<T> for SocketUpdate<Sink, T>

fn from(value: T) -> Self

Converts to this type from the input type.

impl<Sink: Hash, T: Hash> Hash for SocketUpdate<Sink, T>

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<Sink: Ord, T: Ord> Ord for SocketUpdate<Sink, T>

fn cmp(&self, other: &SocketUpdate<Sink, T>) -> 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<Sink: PartialEq, T: PartialEq> PartialEq for SocketUpdate<Sink, T>

fn eq(&self, other: &SocketUpdate<Sink, T>) -> 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<Sink: PartialOrd, T: PartialOrd> PartialOrd for SocketUpdate<Sink, T>

fn partial_cmp(&self, other: &SocketUpdate<Sink, T>) -> 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<Sink, T> Serialize for SocketUpdate<Sink, T>

where Sink: Serialize, T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Sink: Copy, T: Copy> Copy for SocketUpdate<Sink, T>

impl<Sink: Eq, T: Eq> Eq for SocketUpdate<Sink, T>

impl<Sink, T> StructuralPartialEq for SocketUpdate<Sink, T>