Struct JsonRpcDispatcher 

pub struct JsonRpcDispatcher { /* private fields */ }

JSON-RPC 2.0 request dispatcher.

Routes incoming JSON-RPC requests to the underlying RequestHandler. Optionally applies CORS headers to all responses.

Also serves the agent card at GET /.well-known/agent-card.json so that JSON-RPC servers can participate in agent card discovery (spec §8.3).

Implementations

impl JsonRpcDispatcher

pub fn new(handler: Arc<RequestHandler>) -> Self

Creates a new dispatcher wrapping the given handler with default configuration.

pub fn with_config(handler: Arc<RequestHandler>, config: DispatchConfig) -> Self

Creates a new dispatcher with the given configuration.

pub fn with_cors(self, cors: CorsConfig) -> Self

Sets CORS configuration for this dispatcher.

When set, all responses will include CORS headers, and OPTIONS preflight requests will be handled automatically.

pub async fn dispatch( &self, req: Request<Incoming>, ) -> Response<BoxBody<Bytes, Infallible>>

Dispatches a JSON-RPC request and returns an HTTP response.

For SendStreamingMessage and SubscribeToTask, the response uses SSE (text/event-stream). All other methods return JSON.

JSON-RPC errors are always returned as HTTP 200 with an error body. For the two streaming methods that includes an error raised before the stream starts: it is a plain application/json JSON-RPC error response, not SSE. The official conformance kit (a2aproject/a2a-tck) requires this shape — it treats any text/event-stream answer as a successful stream (STREAM-SUB-003/004). a2a-go v2.5.0’s client reads streaming answers only as SSE and so loses these errors; that is a2a-go’s divergence, pinned by scripts/go_sdk_interop.sh.

Trait Implementations

impl Debug for JsonRpcDispatcher

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

Formats the value using the given formatter.

impl Dispatcher for JsonRpcDispatcher

fn dispatch( &self, req: Request<Incoming>, ) -> Pin<Box<dyn Future<Output = DispatchResponse> + Send + '_>>

Dispatches an HTTP request and returns a response.

fn request_handler(&self) -> Option<&Arc<RequestHandler>>

The handler whose tasks this dispatcher starts, if it has one.