Struct tokio::sync::mpsc::chan::Tx

pub(crate) struct Tx<T, S> {
    inner: Arc<Chan<T, S>>,
}

Channel sender.

Fields

inner: Arc<Chan<T, S>>

Implementations

impl<T, S> Tx<T, S>

fn new(chan: Arc<Chan<T, S>>) -> Tx<T, S>

pub(super) fn strong_count(&self) -> usize

pub(super) fn weak_count(&self) -> usize

pub(super) fn downgrade(&self) -> Arc<Chan<T, S>>

pub(super) fn upgrade(chan: Arc<Chan<T, S>>) -> Option<Self>

pub(super) fn semaphore(&self) -> &S

pub(crate) fn send(&self, value: T)

Send a message and notify the receiver.

pub(crate) fn wake_rx(&self)

Wake the receive half

pub(crate) fn same_channel(&self, other: &Self) -> bool

Returns true if senders belong to the same channel.

impl<T, S: Semaphore> Tx<T, S>

pub(crate) fn is_closed(&self) -> bool

pub(crate) async fn closed(&self)

Trait Implementations

impl<T, S> Clone for Tx<T, S>

fn clone(&self) -> Tx<T, S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T, S: Debug> Debug for Tx<T, S>

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

Formats the value using the given formatter.

impl<T, S> Drop for Tx<T, S>

fn drop(&mut self)

Executes the destructor for this type.