Struct Sender 

pub struct Sender<T, B: Eq + Hash + Clone> { /* private fields */ }

A sender that wraps Sender and tracks message delivery.

Implementations

impl<T, B: Eq + Hash + Clone> Sender<T, B>

pub async fn send( &mut self, batch: Option<B>, data: T, ) -> Result<u64, SendError>

Sends a message with an optional batch ID and returns a delivery guard.

pub fn try_send( &mut self, batch: Option<B>, data: T, ) -> Result<u64, TrySendError<Message<T, B>>>

Tries to send a message without blocking.

pub fn watermark(&self) -> u64

Returns the current delivery watermark (highest sequence number where all messages up to and including it have been delivered).

pub fn pending(&self, batch: B) -> usize

Returns the number of pending messages for a specific batch.

Trait Implementations

impl<T: Clone, B: Clone + Eq + Hash + Clone> Clone for Sender<T, B>

fn clone(&self) -> Sender<T, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.