Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Manager coordinating the lifecycle of tracked tasks.

Implementations

impl TaskManager

pub fn new() -> TaskManager

Create a new task manager retaining terminal tasks for DEFAULT_TASK_TTL_MS when the request omits a ttl.

pub fn with_default_ttl(default_ttl_ms: Option<u64>) -> TaskManager

Create a task manager with a custom default retention (milliseconds) for tasks whose request omits ttl. Pass None for unlimited retention (such tasks are never TTL-evicted).

pub const fn with_poll_interval( self, poll_interval_ms: Option<u64>, ) -> TaskManager

Suggest a polling interval (milliseconds) on every task this manager creates.

pollInterval is optional in the spec — a requestor that receives none simply picks its own rate. Setting one lets a server say how often it expects to be polled, which is the difference between a client polling sensibly and polling as fast as it can.

pub fn set_observer( &self, observer: Arc<dyn TaskObserver>, ) -> Result<(), McpError>

Register the observer notified of every status transition.

Errors

Returns an error if an observer was already registered; a manager observes at most once so a late registration cannot silently replace an earlier one and lose events.

pub fn create(self: &Arc<TaskManager>, ttl: Option<u64>) -> TaskHandle

Create a new working task and return a handle to it.

A None ttl is materialized to the manager’s default so the returned task reports its actual retention. Expired terminal tasks are swept first.

pub fn get(&self, id: &TaskId) -> Option<TaskState>

Get a snapshot of a task’s state by ID.

pub fn list(&self) -> Vec<Task>

List all tracked tasks.

pub fn payload(&self, id: &TaskId) -> Option<TaskPayload>

Get the stored outcome of a terminal task, if available.

pub async fn wait_terminal(&self, id: &TaskId) -> Option<TaskState>

Wait until the task reaches a terminal status, returning its final state. Returns None if the task is unknown (or evicted while waiting).

The wait parks on a per-task event notified by terminal transitions; no lock is held across an await.

pub fn cancel(&self, id: &TaskId) -> Result<(), McpError>

Cancel a task.

Cancelling a task already in a terminal status is rejected with invalid params (spec).

pub fn cleanup(&self, max_age: Duration)

Remove terminal tasks older than max_age.

pub fn cleanup_expired(&self)

Evict terminal tasks whose age since creation exceeds their own ttl (milliseconds). Non-terminal tasks are always kept; a task with ttl None (unlimited) is never evicted. Called on create and on task-store access, so no timer is required.

Trait Implementations

impl Debug for TaskManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for TaskManager

fn default() -> TaskManager

Returns the “default value” for a type.