Struct network_clique::mock::Channel

pub struct Channel<T>(pub UnboundedSender<T>, pub Arc<Mutex<UnboundedReceiver<T>>>);

Tuple Fields

0: UnboundedSender<T>

1: Arc<Mutex<UnboundedReceiver<T>>>

Implementations

impl<T> Channel<T>

pub fn new() -> Self

pub fn send(&self, msg: T)

pub async fn next(&mut self) -> Option<T>

pub async fn take(&mut self, n: usize) -> Vec<T>

pub async fn try_next(&self) -> Option<T>

pub async fn close(self) -> Option<T>

Trait Implementations

impl<T: Clone> Clone for Channel<T>

fn clone(&self) -> Channel<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Default for Channel<T>

fn default() -> Self

Returns the “default value” for a type.