Struct StreamableHttpTransport 

pub struct StreamableHttpTransport { /* private fields */ }

Streaming HTTP transport for long-lived MCP connections.

This transport uses HTTP streaming (chunked transfer encoding) for server-to-client messages and regular POST requests for client-to-server messages.

Implementations

impl StreamableHttpTransport

pub fn new() -> StreamableHttpTransport

Creates a new streaming HTTP transport.

pub fn push_request(&self, request: JsonRpcRequest)

Pushes a request into the queue (from HTTP handler).

pub fn pop_response(&self) -> Option<JsonRpcResponse>

Pops a response from the queue (for HTTP streaming).

pub fn has_responses(&self) -> bool

Checks if there are pending responses.

pub fn request_queue(&self) -> Arc<Mutex<VecDeque<JsonRpcRequest>>>

Returns the request queue for external access.

pub fn response_queue(&self) -> Arc<Mutex<VecDeque<JsonRpcResponse>>>

Returns the response queue for external access.

Trait Implementations

impl Default for StreamableHttpTransport

fn default() -> StreamableHttpTransport

Returns the “default value” for a type.

impl Transport for StreamableHttpTransport

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.