Struct MailboxTx 

pub struct MailboxTx<M> { /* private fields */ }

Implementations

impl<M> MailboxTx<M>

pub fn new( user_tx: Sender<M>, ctl_tx: Sender<ControlMsg>, meter: Arc<MailboxMeter>, pid: Pid, overload: OverloadConfig, ) -> Self

pub fn pid(&self) -> Pid

pub async fn send_wait(&self, msg: M) -> Result<(), TellError>

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

pub fn try_send_control(&self, msg: ControlMsg) -> Result<(), TellError>

pub async fn send_control_wait(&self, msg: ControlMsg) -> Result<(), TellError>

pub fn stop(&self) -> Result<(), TellError>

pub async fn stop_wait(&self) -> Result<(), TellError>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn control_len(&self) -> usize

pub fn inflight_count(&self) -> usize

pub fn idle_for(&self) -> Duration

pub fn silence_for(&self) -> Duration

pub fn incarnation(&self) -> u64

pub fn is_closed(&self) -> bool

pub fn is_terminated(&self) -> bool

pub async fn ask_wait<F, R>(&self, factory: F) -> Result<R, AskError>

where F: FnOnce(Sender<R>) -> M,

pub async fn ask_wait_timeout<F, R>( &self, factory: F, timeout: Duration, ) -> Result<R, AskError>

where F: FnOnce(Sender<R>) -> M,

Trait Implementations

impl<M> Clone for MailboxTx<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M> From<MailboxTx<M>> for LocalRef<M>

fn from(tx: MailboxTx<M>) -> Self

Converts to this type from the input type.