Struct GCJobManager 

pub struct GCJobManager { /* private fields */ }

Job manager for tracking pending GC requests.

Implementations

impl GCJobManager

pub fn new() -> Self

Create a new GC job manager.

pub fn with_timeout(default_timeout: Duration) -> Self

Create a new GC job manager with a custom default timeout.

pub fn create_job( &self, appid: u32, response_msg_type: u32, ) -> Receiver<GCJobResponse>

Create a new job and return the response receiver.

The job is keyed by (appid, response_msg_type). When a GC message matching this key arrives, the job will be completed.

pub fn create_job_with_timeout( &self, appid: u32, response_msg_type: u32, timeout: Duration, ) -> Receiver<GCJobResponse>

Create a new job with a custom timeout.

pub fn try_complete(&self, appid: u32, msg_type: u32, payload: Vec<u8>) -> bool

Try to complete a job with a GC message.

Returns true if a matching job was found and completed.

pub fn cleanup_expired(&self)

Clean up expired jobs.

pub fn pending_count(&self) -> usize

Get the number of pending jobs.

Trait Implementations

impl Clone for GCJobManager

fn clone(&self) -> GCJobManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for GCJobManager

fn default() -> Self

Returns the “default value” for a type.