a2a-rs 0.8.0

Rust implementation of the Agent-to-Agent (A2A) Protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

//! Streaming adapters: real-time fan-out of task updates to subscribers.
//!
//! This is the technical-concern bucket for the [`AsyncStreamingHandler`] port
//! (`.claude/rules/hexagonal_architecture.md` §3). It holds the in-process
//! subscriber registry — distinct from the storage adapters, which are
//! persistence-only and do not fan out updates.
//!
//! The ids a stream is resumed by, and the events it replays, come from an
//! [`AsyncEventLog`] the fan-out is built over, so durability is a matter of
//! which log it was given.
//!
//! [`AsyncStreamingHandler`]: crate::port::AsyncStreamingHandler
//! [`AsyncEventLog`]: crate::port::AsyncEventLog

mod fanout;

pub use fanout::{InMemoryStreamingHandler, StreamingFanout};