Struct glommio::channels::channel_mesh::Receivers

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

Receiver side

Implementations

impl<T: Send> Receivers<T>

pub fn peer_id(&self) -> usize

Index of the local executor in the list of all peers

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

Index of the local executor in the list of consumers.

pub fn nr_producers(&self) -> usize

Number of peers from which message can be received.

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

Receive a message from the idx-th producer

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

See ConnectedReceiver.recv for how the underlying sender works.

pub fn streams(&mut self) -> Vec<(usize, ConnectedReceiver<T>)>

Returns a vec of ConnectedReceivers with the id of their upstream producers.

Trait Implementations

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

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

Formats the value using the given formatter.