Struct TailChoppingRouter 

pub struct TailChoppingRouter<M: Send + Clone + 'static> {
    pub interval: Duration,
    pub within: Duration,
    /* private fields */
}

Fields

interval: Duration

How long to wait for the previous attempt’s reply before firing the next. A Duration::ZERO interval makes this equivalent to scatter-gather.

within: Duration

Hard ceiling on how long the caller will wait overall.

Implementations

impl<M: Send + Clone + 'static> TailChoppingRouter<M>

pub fn new( routees: Vec<ActorRef<M>>, interval: Duration, within: Duration, ) -> Self

pub fn routee_count(&self) -> usize

Number of routees currently registered.

pub fn next_attempt(&self) -> Option<&ActorRef<M>>

Pick the next attempt’s recipient; returns None when the router is empty.

pub fn max_attempts(&self) -> usize

Maximum number of distinct attempts within within.