Struct HttpTransport 

pub struct HttpTransport<R, W> { /* private fields */ }

HTTP transport for stateless MCP communication.

In stateless mode, each HTTP request contains a single JSON-RPC message and receives a single response. This is suitable for simple integrations where session state is not needed.

Implementations

impl<R, W> HttpTransport<R, W>

where R: Read, W: Write,

pub fn new(reader: R, writer: W) -> HttpTransport<R, W>

Creates a new HTTP transport.

pub fn read_request(&mut self) -> Result<HttpRequest, HttpError>

Reads an HTTP request from the reader.

pub fn write_response( &mut self, response: &HttpResponse, ) -> Result<(), HttpError>

Writes an HTTP response to the writer.

pub fn queue_response(&mut self, response: JsonRpcResponse)

Queues a response to be sent.

Trait Implementations

impl<R, W> Transport for HttpTransport<R, W>

where R: Read, W: Write,

fn send( &mut self, cx: &Cx, message: &JsonRpcMessage, ) -> Result<(), TransportError>

Send a JSON-RPC message through this transport.

fn recv(&mut self, cx: &Cx) -> Result<JsonRpcMessage, TransportError>

Receive the next JSON-RPC message from this transport.

fn close(&mut self) -> Result<(), TransportError>

Close the transport gracefully.

fn send_request( &mut self, cx: &Cx, request: &JsonRpcRequest, ) -> Result<(), TransportError>

Send a request through this transport.

fn send_response( &mut self, cx: &Cx, response: &JsonRpcResponse, ) -> Result<(), TransportError>

Send a response through this transport.