Struct reactive_messaging::prelude::Peer

pub struct Peer<MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> {
    pub peer_id: u32,
    pub sender: Arc<Atomic<'static, MessagesType, BUFFER_SIZE, 1>>,
    pub peer_address: SocketAddr,
}

Represents a channel to a peer able to send out MessageType kinds of messages from “here” to “there”

Fields

peer_id: u32

sender: Arc<Atomic<'static, MessagesType, BUFFER_SIZE, 1>>

peer_address: SocketAddr

Implementations

impl<MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> Peer<MessagesType>

pub fn new( sender: Arc<Atomic<'static, MessagesType, BUFFER_SIZE, 1>>, peer_address: SocketAddr ) -> Self

Trait Implementations

impl<MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> Debug for Peer<MessagesType>

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

Formats the value using the given formatter.