Struct EventEmitter 

pub struct EventEmitter<'a> {
    pub ctx: &'a RequestContext,
    pub queue: &'a dyn EventQueueWriter,
}

Ergonomic helper for emitting status and artifact events from an executor.

Caches task_id and context_id from the RequestContext so that every event emission is a one-liner instead of a 7-line struct literal.

Example

use a2a_protocol_server::executor_helpers::EventEmitter;
use a2a_protocol_types::task::TaskState;
use a2a_protocol_types::message::Part;

let emit = EventEmitter::new(ctx, queue);
emit.status(TaskState::Working).await?;
emit.artifact("result", vec![Part::text("hello")], None, Some(true)).await?;
emit.status(TaskState::Completed).await?;

Fields

ctx: &'a RequestContext

The request context for this execution.

queue: &'a dyn EventQueueWriter

The event queue writer for this execution.

Implementations

impl<'a> EventEmitter<'a>

pub fn new(ctx: &'a RequestContext, queue: &'a dyn EventQueueWriter) -> Self

Creates a new EventEmitter from the given context and queue.

pub async fn status(&self, state: TaskState) -> A2aResult<()>

Emits a status update event.

Errors

Returns an error if the event queue write fails.

pub async fn artifact( &self, id: &str, parts: Vec<Part>, append: Option<bool>, last_chunk: Option<bool>, ) -> A2aResult<()>

Emits an artifact update event.

Errors

Returns an error if the event queue write fails.

pub fn is_cancelled(&self) -> bool

Returns true if the task has been cancelled.