Enum keebrs::net::Msg

pub enum Msg<T> {
    Broadcast {
        to: i8,
        from: i8,
        data: T,
    },
    Direct {
        to: i8,
        from: i8,
        data: T,
    },
}

Variants

Broadcast

Fields of Broadcast

to: i8from: i8data: T

Direct

Fields of Direct

to: i8from: i8data: T

Implementations

impl<T> Msg<T>

pub fn broadcast(data: T) -> Self

pub fn direct(to: i8, data: T) -> Self

pub fn set_from(&mut self, new_from: i8)

pub fn unpack(self) -> (i8, T)

Trait Implementations

impl<T: Clone> Clone for Msg<T>

fn clone(&self) -> Msg<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Copy> Copy for Msg<T>

impl<T: Debug> Debug for Msg<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Msg<T> where
    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<T: Eq> Eq for Msg<T>

impl<T: PartialEq> PartialEq<Msg<T>> for Msg<T>

fn eq(&self, other: &Msg<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Msg<T>) -> bool

This method tests for !=.

impl<T> Serialize for Msg<T> where
    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<R, T> Sink<Msg<T>> for Background<R, T> where
    R: RawMutex, 

type Error = !

The type of value produced by the sink when an error occurs.

fn poll_ready(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, item: Msg<T>) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl<T, LW, LR, RW, RR> Sink<Msg<T>> for ChainNet<T, LW, LR, RW, RR> where
    LW: Write,
    RW: Write<Error = LW::Error>,
    T: Serialize + Clone, 

type Error = WriteFrameError<LW::Error, Error>

The type of value produced by the sink when an error occurs.

fn poll_ready(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn poll_flush(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn start_send(self: Pin<&mut Self>, item: Msg<T>) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_close(
    self: Pin<&mut Self>,
    _: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl<T> StructuralEq for Msg<T>

impl<T> StructuralPartialEq for Msg<T>