Struct tikv_util::mpsc::LooseBoundedSender

[+] Show declaration

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

[−] Expand description

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>[+]

[+] Show hidden undocumented items

fn clone(&self) -> LooseBoundedSender<T>[−]

Returns a copy of the value.

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

Performs copy-assignment from source.