Struct HttpServer 

pub struct HttpServer<P, A, Auth = NoopAuthenticator>
where
    P: A2aService + Send + Sync + 'static,
    A: AgentInfoProvider + Send + Sync + 'static,
    Auth: Authenticator + Send + Sync + 'static,
{ /* private fields */ }

HTTP server for the A2A protocol

Implementations

impl<P, A> HttpServer<P, A>

where P: A2aService + Send + Sync + 'static, A: AgentInfoProvider + Send + Sync + 'static,

pub fn new(processor: P, agent_info: A, address: String) -> Self

Create a new HTTP server with the given processor and agent info provider

impl<P, A, Auth> HttpServer<P, A, Auth>

where P: A2aService + Send + Sync + 'static, A: AgentInfoProvider + Send + Sync + 'static, Auth: Authenticator + Clone + Send + Sync + 'static,

pub fn with_auth( processor: P, agent_info: A, address: String, authenticator: Auth, ) -> Self

Create a new HTTP server with authentication

pub async fn start(&self) -> Result<(), A2AError>

Start the HTTP server on the configured address.

pub async fn serve_on(&self, listener: TcpListener) -> Result<(), A2AError>

Serve on a listener the caller has already bound.

start binds the address itself, which leaves a caller that asked for port 0 no way to learn which port it got, and any caller no way to know the socket is accepting yet. Binding first answers both: listener.local_addr() reports the real address, and the kernel queues connections from the moment of the bind, so a client may connect before this future is ever polled. That is what a test needs to skip the “sleep and hope” step, and what lets a supervisor hand out port 0 and report back the port the agent actually listens on.