Struct kaspa_utils::channel::Channel

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

Multiple producers multiple consumers channel

Implementations

impl<T> Channel<T>

pub fn new(channel: (Sender<T>, Receiver<T>)) -> Channel<T>

pub fn bounded(capacity: usize) -> Channel<T>

pub fn sender(&self) -> Sender<T>

pub fn receiver(&self) -> Receiver<T>

pub fn close(&self)

pub fn is_closed(&self) -> bool

pub async fn recv(&self) -> Result<T, RecvError>

pub fn try_recv(&self) -> Result<T, TryRecvError>

pub async fn send(&self, msg: T) -> Result<(), SendError<T>>

pub fn try_send(&self, msg: T) -> Result<(), TrySendError<T>>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn receiver_count(&self) -> usize

pub fn sender_count(&self) -> usize

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: Debug> Debug for Channel<T>

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

Formats the value using the given formatter.

impl<T> Default for Channel<T>

Default for a Channel<T> is unbounded

fn default() -> Self

Returns the “default value” for a type.