Struct reactive_messaging::prelude::Peer

pub struct Peer<const BUFFERED_MESSAGES_PER_PEER_COUNT: usize, MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> {
    pub peer_id: u32,
    pub sender: Arc<Atomic<'static, MessagesType, BUFFERED_MESSAGES_PER_PEER_COUNT, 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, BUFFERED_MESSAGES_PER_PEER_COUNT, 1>>

peer_address: SocketAddr

Implementations

impl<const BUFFERED_MESSAGES_PER_PEER_COUNT: usize, MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, MessagesType>

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

Trait Implementations

impl<const BUFFERED_MESSAGES_PER_PEER_COUNT: usize, MessagesType: 'static + Send + Sync + PartialEq + Debug + ReactiveMessagingSerializer<MessagesType>> Debug for Peer<BUFFERED_MESSAGES_PER_PEER_COUNT, MessagesType>

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

Formats the value using the given formatter.