Struct tikv_util::mpsc::LooseBoundedSender

pub struct LooseBoundedSender<T> {
    sender: Sender<T>,
    tried_cnt: Cell<usize>,
    limit: usize,
}

A sender of channel that limits the maximun pending messages count loosely.

Fields

sender: Sender<T>

tried_cnt: Cell<usize>

limit: usize

Implementations

impl<T> LooseBoundedSender<T>

pub fn len(&self) -> usize

Returns the number of messages in the channel.

pub fn is_empty(&self) -> bool

Returns true if the channel is empty.

Note: Zero-capacity channels are always empty.

pub fn force_send(&self, t: T) -> Result<(), SendError<T>>

Send a message regardless its capacity limit.

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

Attempts to send a message into the channel without blocking.

pub fn close_sender(&self)

Stop the sender from sending any further messages.

pub fn is_sender_connected(&self) -> bool

Check if the sender is still connected.

Trait Implementations

impl<T> Clone for LooseBoundedSender<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.