Struct TaskEvent 

#[non_exhaustive]
pub struct TaskEvent {
    pub task_id: String,
    pub status: TaskStatus,
    pub message: Option<Message>,
    pub final_event: bool,
    pub event_id: u64,
}

Lifecycle event emitted by crate::task_store::A2aTaskStore on each mutating write. Serialised as the SSE data: payload for SubscribeToTask / SendStreamingMessage responses in the HTTP transport (the http cargo feature, not yet wired).

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

task_id: String

The task whose state transitioned.

status: TaskStatus

Current status post-transition.

message: Option<Message>

Last message in the task history, if any.

final_event: bool

true if status is terminal (Completed / Failed / Canceled / Rejected); stream consumers close after receiving it.

event_id: u64

Monotonic per-task event id used by SSE Last-Event-ID resumption. Set by the HTTP transport when the event is yielded; defaults to 0 for events constructed outside the transport (e.g. synthetic initial replays from task_store).

Implementations

impl TaskEvent

pub fn new( task_id: impl Into<String>, status: TaskStatus, message: Option<Message>, final_event: bool, ) -> Self

Construct a TaskEvent. The only public constructor — required because #[non_exhaustive] prevents struct-literal construction outside this crate. event_id defaults to 0; the HTTP transport overwrites it when the event is yielded into an SSE stream.

pub fn with_event_id(self, event_id: u64) -> Self

Override the monotonic event id assigned by the store or transport.

Used by A2aTaskStore::put to stamp broadcast events, and by dispatch_send_streaming / subscribe_snapshot_then_tail to stamp synthetic initial events before they enter the SSE stream.

Trait Implementations

impl Clone for TaskEvent

fn clone(&self) -> TaskEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TaskEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.