Struct ClientTaskTimer 

pub struct ClientTaskTimer<F: ClientFacts> { /* private fields */ }

Implementations

impl<F: ClientFacts> ClientTaskTimer<F>

pub fn new(conn_id: String, task_timeout: usize, thresholds: usize) -> Self

pub fn pending_task_count_ref(&self) -> &AtomicU64

pub fn clean_pending_tasks(&mut self, facts: &F)

pub fn check_pending_tasks_empty(&mut self) -> bool

pub async fn reg_task(&self, task: F::Task, wg: WaitGroupGuard)

pub fn stop_reg_task(&mut self)

pub async fn take_task(&mut self, seq: u64) -> Option<ClientTaskItem<F::Task>>

pub fn poll_sent_task<'a>(&mut self, ctx: &mut Context<'_>) -> bool

pub fn adjust_task_queue(&mut self, facts: &F)

Trait Implementations

impl<T: ClientFacts> Send for ClientTaskTimer<T>

impl<T: ClientFacts> Sync for ClientTaskTimer<T>