Struct Sender 

pub struct Sender<Message> { /* private fields */ }

Where an application-defined source puts its messages.

The source is handed one by Subscription::run or run_blocking. Whether a send waits is the source’s Admission: under Admission::bounded a send waits while the queue is full, and under Admission::latest it never waits.

Implementations

impl<Message: Send + 'static> Sender<Message>

pub async fn send(&self, message: Message) -> Result<(), SendError>

Sends a message, waiting where the source’s admission says to.

pub fn blocking_send(&self, message: Message) -> Result<(), SendError>

Sends a message from a thread that may block, for a source that is not asynchronous.

Trait Implementations

impl<Message> Clone for Sender<Message>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Message> Debug for Sender<Message>

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

Formats the value using the given formatter.