Struct ThreadSender 

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

A thread-safe channel sender for intra-process communication.

This is the sending half of a ThreadChannel. It can be cloned to create multiple producers that send to the same channel.

Implementations

impl<T> ThreadSender<T>

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

Send a message through the channel.

This method blocks if the channel is bounded and full.

Errors

Returns IpcError::Closed if the channel has been shutdown or all receivers have been dropped.

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

Try to send a message without blocking.

Errors

• IpcError::Closed if the channel has been shutdown or all receivers have been dropped.
• IpcError::WouldBlock if the channel is full (bounded channels only).

pub fn send_timeout(&self, msg: T, timeout: Duration) -> Result<()>

Send a message with a timeout.

Errors

• IpcError::Closed if the channel has been shutdown or all receivers have been dropped.
• IpcError::Timeout if the timeout expires before the message can be sent.

pub fn is_empty(&self) -> bool

Check if the channel is empty.

pub fn is_full(&self) -> bool

Check if the channel is full (always false for unbounded channels).

pub fn len(&self) -> usize

Get the number of messages in the channel.

pub fn capacity(&self) -> Option<usize>

Get the capacity of the channel (None for unbounded channels).

pub fn is_shutdown(&self) -> bool

Check if the channel has been shutdown.

pub fn shutdown(&self)

Shutdown the channel.

Trait Implementations

impl<T> Clone for ThreadSender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ThreadSender<T>

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

Formats the value using the given formatter.

impl<T> GracefulChannel for ThreadSender<T>

fn shutdown(&self)

Signal the channel to shutdown

fn is_shutdown(&self) -> bool

Check if the channel has been signaled to shutdown

fn drain(&self) -> Result<()>

Wait for all pending messages to be processed

fn shutdown_timeout(&self, timeout: Duration) -> Result<()>

Shutdown with a timeout