Struct dcs2::communication::messages::Package

pub struct Package<Id: NodeId, B: Body> {
    pub header: Header<Id>,
    pub body: B,
}

Fields

header: Header<Id>

body: B

Implementations

impl<Id: NodeId, B: Body> Package<Id, B>

pub fn get_message(&self) -> &B

pub fn get_mut_message(&mut self) -> &mut B

pub fn get_sender(&self) -> Id

pub fn get_receiver(&self) -> Id

Trait Implementations

impl<Id: Clone + NodeId, B: Clone + Body> Clone for Package<Id, B>

fn clone(&self) -> Package<Id, B>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Id: Debug + NodeId, B: Debug + Body> Debug for Package<Id, B>

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

Formats the value using the given formatter.

impl<Id: NodeId, B: Body> Display for Package<Id, B>

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

Formats the value using the given formatter.

impl<Conn: Connection, Addr: Address, F, R: Router<Address = Addr>> InMsgQueue<Package<SystemNodeId, Vec<u8, MESSAGE_BUFFER_MAX_SIZE>>> for GenericCommunicationService<Conn, Addr, F, R>

where F: ConnectionFactory<Address = Addr, Connection = Conn>,

fn pop(&mut self) -> Option<GenericPackage>

Returns some value from the queue or teturns None. Blocking behavior is not guaranteed nor enforced by this method.

impl<Conn: Connection, Addr: Address, F, R: Router<Address = Addr>> OutMsgQueue<Package<SystemNodeId, Vec<u8, MESSAGE_BUFFER_MAX_SIZE>>> for GenericCommunicationService<Conn, Addr, F, R>

where F: ConnectionFactory<Address = Addr, Connection = Conn>,

fn push(&mut self, pkg: GenericPackage)

Pushes a value in the queue. Blocking behavior nor enforced is not guaranteed by this method. Blocking behavior is not guaranteed nor enforced by this method.

impl<Id, B> Serialize for Package<Id, B>

where Id: Serialize + NodeId, B: Serialize + Body,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Conn: Connection, Addr: Address, F, R: Router<Address = Addr>> CommunicationService<Package<SystemNodeId, Vec<u8, MESSAGE_BUFFER_MAX_SIZE>>> for GenericCommunicationService<Conn, Addr, F, R>

where F: ConnectionFactory<Address = Addr, Connection = Conn>,