Struct Task 

#[non_exhaustive]
pub struct Task { /* private fields */ }

Ergonomic wrapper over proto Task.

Implementations

impl Task

pub fn new(id: impl Into<String>, status: TaskStatus) -> Self

pub fn with_context_id(self, context_id: impl Into<String>) -> Self

pub fn id(&self) -> &str

pub fn context_id(&self) -> &str

pub fn status(&self) -> Option<TaskStatus>

pub fn history(&self) -> &[Message]

pub fn artifacts(&self) -> &[Artifact]

pub fn append_message(&mut self, message: Message)

pub fn append_artifact(&mut self, artifact: Artifact)

pub fn merge_artifact( &mut self, artifact: Artifact, append: bool, _last_chunk: bool, )

Merge an artifact using A2A streaming append semantics.

• append = true: if an artifact with the same artifactId is already on the task, extend its parts with the incoming parts (same as a streaming-chunk continuation). Otherwise, append as a new entry.
• append = false: append unconditionally (new entry or caller tolerates duplicate ids).

The last_chunk flag is transport-only metadata — it is not persisted on the task. It is accepted here so callers can keep the signature symmetric with the streaming wire event payload and not drop the parameter separately.

This mirrors the server storage append-artifact semantics so that in-memory task mutations and the storage layer converge on the same view. The storage trait lives in the server crate; this helper is the dependency-free equivalent for wrapper callers.

pub fn set_status(&mut self, status: TaskStatus)

Set the task’s status. This is the low-level escape hatch — prefer complete(), fail(), etc. for common transitions.

pub fn complete(&mut self)

Mark the task as completed.

pub fn fail(&mut self, message: impl Into<String>)

Mark the task as failed with an optional message.

pub fn push_text_artifact( &mut self, artifact_id: impl Into<String>, name: impl Into<String>, text: impl Into<String>, )

Add a text artifact to the task.

pub fn as_proto(&self) -> &Task

pub fn as_proto_mut(&mut self) -> &mut Task

pub fn into_proto(self) -> Task

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl From<Task> for Task

fn from(task: Task) -> Self

Converts to this type from the input type.

impl Serialize for Task

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.

impl TryFrom<Task> for Task

type Error = A2aTypeError

The type returned in the event of a conversion error.

fn try_from(inner: Task) -> Result<Self, Self::Error>

Performs the conversion.