Struct glommio::channels::channel_mesh::Senders

pub struct Senders<T: Send> { /* fields omitted */ }

Sender side

Implementations

impl<T: Send> Senders<T>

pub fn peer_id(&self) -> usize

Index of the local executor in the list of all peers

pub fn producer_id(&self) -> Option<usize>

Index of the local executor in the list of producers

pub fn nr_consumers(&self) -> usize

Number of peers to which messages can be sent.

pub async fn send_to(&self, idx: usize, msg: T) -> Result<(), T>

Send a message to the idx-th consumer

It returns a GlommioError::IoError encapsulating a InvalidInput if the idx is out of the range of available senders, or the sender is a placeholder in the case of full mesh.

See ConnectedSender.send for how the underlying sender works.

pub fn try_send_to(&self, idx: usize, msg: T) -> Result<(), T>

Send a message to the idx-th consumer

It returns a GlommioError::IoError encapsulating a InvalidInput if the idx is out of the range of available senders, or the sender is a placeholder in the case of full mesh.

See ConnectedSender.try_send for how the underlying sender works.

pub fn close(&self)

Close the senders

Trait Implementations

impl<T: Debug + Send> Debug for Senders<T>

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

Formats the value using the given formatter.