Struct tokio::sync::mpsc::list::Tx

pub(crate) struct Tx<T> {
    block_tail: AtomicPtr<Block<T>>,
    tail_position: AtomicUsize,
}

List queue transmit handle.

Fields

block_tail: AtomicPtr<Block<T>>

Tail in the Block mpmc list.

tail_position: AtomicUsize

Position to push the next message. This references a block and offset into the block.

Implementations

impl<T> Tx<T>

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

Pushes a value into the list.

pub(crate) fn close(&self)

Closes the send half of the list.

Similar process as pushing a value, but instead of writing the value & setting the ready flag, the TX_CLOSED flag is set on the block.

fn find_block(&self, slot_index: usize) -> NonNull<Block<T>>

pub(crate) unsafe fn reclaim_block(&self, block: NonNull<Block<T>>)

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

Trait Implementations

impl<T> Debug for Tx<T>

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

Formats the value using the given formatter.