Struct DefaultStreamingTaskHandler 

pub struct DefaultStreamingTaskHandler { /* private fields */ }

Opt-in default message/stream handler wired up by [A2AServerBuilder::with_default_streaming_task_handler] / [A2AServerBuilder::with_default_task_handlers].

When an Agent is configured, the handler iterates generate_content_stream from the inference gateway, parses each OpenAI-style delta, and emits a TaskArtifactUpdateEvent per non-empty content chunk (append: true, shared artifact_id) - clients see the reply build up in real time. The stream terminates with a final last_chunk: true artifact + a Completed status update.

Without an agent, emits a single instructional artifact + Completed so the bundled defaults remain usable for examples and tests.

Implementations

impl DefaultStreamingTaskHandler

pub fn new(agent: Option<Arc<Agent>>) -> Self

Trait Implementations

impl Debug for DefaultStreamingTaskHandler

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

Formats the value using the given formatter.

impl StreamableTaskHandler for DefaultStreamingTaskHandler

fn handle_streaming_task<'life0, 'async_trait>( &'life0 self, task: Task, _message: Option<A2AMessage>, emitter: StreamEmitter, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Drive a message/stream interaction.