Struct A2aContext 

pub struct A2aContext {
    pub task: Option<Task>,
    pub accepted_output_modes: Vec<String>,
    /* private fields */
}

What a message handler sees besides the message.

Fields

task: Option<Task>

The task this message continues (one waiting for input), if any.

accepted_output_modes: Vec<String>

Media types the client accepts in replies (empty: any).

Implementations

impl A2aContext

pub fn task_id(&self) -> &str

The task id this message belongs to (new, or the continued task’s).

pub fn context_id(&self) -> &str

The conversation’s context id.

pub fn task( &self, state: TaskState, message: Option<Message>, artifacts: Vec<Artifact>, ) -> Task

A task in state with an optional agent message and artifacts; its history holds the earlier messages and this one.

pub fn complete(&self, artifacts: Vec<Artifact>) -> Task

A completed task with these artifacts.

pub fn fail(&self, reason: &str) -> Task

A failed task, saying why.

pub fn reject(&self, reason: &str) -> Task

A refused task, saying why.

pub fn input_required(&self, question: &str) -> Task

A task waiting for the client to answer question.

pub fn start(&self) -> TaskHandle

Start working on this message in the background: the task is stored (working) at once; return A2aReply::Running(handle) and update it through the handle from any thread. SendMessage waits for it to finish (or ask for input), streams follow it.