Struct seec_channel::multi::MultiReceiver

pub struct MultiReceiver<T> { /* private fields */ }

Implementations

impl<T: RemoteSend> MultiReceiver<T>

pub async fn recv_from_single(&mut self, from: u32) -> Result<T, Error>

pub fn recv_from( &mut self, from: &HashSet<u32> ) -> impl Stream<Item = Result<MsgFrom<T>, Error>> + '_

pub fn recv_all(&mut self) -> impl Stream<Item = Result<MsgFrom<T>, Error>> + '_

pub fn receiver(&mut self, from: u32) -> Option<&mut Receiver<T>>

pub fn receivers(&mut self) -> impl Iterator<Item = (&u32, &mut Receiver<T>)>

Trait Implementations

impl<T: Debug> Debug for MultiReceiver<T>

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

Formats the value using the given formatter.

impl<T> Default for MultiReceiver<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: RemoteSend> ReceiverT<T> for MultiReceiver<T>

type Error = Error

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Option<T>, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,