Enum TaskPushNotification 

pub enum TaskPushNotification {
    StatusUpdate {
        id: String,
        status: TaskStatus,
        error: Option<String>,
    },
    ArtifactUpdate {
        id: String,
        artifact: A2ATaskResult,
    },
}

A push notification emitted by a streaming A2A server (P2-1).

Sent over an SSE connection as data: <json> lines, discriminated by the kind field. Mirrors the A2A TaskStatusUpdateEvent / TaskArtifactUpdateEvent pair.

Variants

StatusUpdate

A task status transition (e.g. submitted → working, or a terminal state). Carries an optional error message when the status is failed.

Fields

id: String

Task id.

status: TaskStatus

New status.

error: Option<String>

Optional error message (present when status is failed).

ArtifactUpdate

A chunk of partial output while the task is still working.

Fields

id: String

Task id.

artifact: A2ATaskResult

Partial (or final) output.

Implementations

impl TaskPushNotification

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

Create a status-update notification.

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

Create a status-update notification carrying an error message.

pub fn artifact(id: impl Into<String>, artifact: A2ATaskResult) -> Self

Create an artifact-update notification.

pub fn id(&self) -> &str

The task id this notification refers to.

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

The current status, if this is a status-update notification.

Trait Implementations

impl Clone for TaskPushNotification

fn clone(&self) -> TaskPushNotification

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskPushNotification

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskPushNotification

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskPushNotification

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.