mcp::transport::StreamableHttpClientTransport Class Reference

Native transport-contract client for Streamable HTTP. More...

#include <http_transport.hpp>

Inheritance diagram for mcp::transport::StreamableHttpClientTransport:

Public Member Functions
	StreamableHttpClientTransport (StreamableHttpClientTransportOptions options)
	StreamableHttpClientTransport (const StreamableHttpClientTransport &)=delete
StreamableHttpClientTransport &	operator= (const StreamableHttpClientTransport &)=delete
std::string_view	name () const noexcept override
	Human-readable transport name for diagnostics.
protocol::Json	diagnostics () const override
	Structured implementation diagnostics.
core::Result< core::Unit >	send (TxMessage message) override
	Sends one JSON-RPC message to the peer.
core::Result< std::optional< RxMessage > >	receive () override
	Receives the next JSON-RPC message from the peer.
core::Result< core::Unit >	close () override
	Closes the transport and unblocks receive() where possible.
Public Member Functions inherited from mcp::transport::Transport< Role >
virtual void	wait_until_ready ()
	Blocks until the transport is ready to process messages.

Additional Inherited Members
Public Types inherited from mcp::transport::Transport< Role >
using	TxMessage = typename MessageTraits< Role >::TxMessage
using	RxMessage = typename MessageTraits< Role >::RxMessage

Detailed Description

Native transport-contract client for Streamable HTTP.

This class exposes Streamable HTTP through transport::ClientTransport while reusing the established client HTTP implementation. Sending requests starts background workers whose responses are returned by receive(); sending a response completes an inbound server-to-client request previously returned by receive(). receive() blocks until a queued message is available or close() completes. Concurrent receive() calls are not supported.

Member Function Documentation

close()

core::Result< core::Unit > mcp::transport::StreamableHttpClientTransport::close ( )

overridevirtual

Closes the transport and unblocks receive() where possible.

Implements mcp::transport::Transport< Role >.

diagnostics()

protocol::Json mcp::transport::StreamableHttpClientTransport::diagnostics ( ) const

overridevirtual

Structured implementation diagnostics.

The default keeps the core contract narrow. Transports with useful state may return keys such as "name", "closed", "inflight", or backend-specific counters. Diagnostics are not part of the wire protocol.

Reimplemented from mcp::transport::Transport< Role >.

name()

std::string_view mcp::transport::StreamableHttpClientTransport::name ( ) const

overridevirtualnoexcept

Human-readable transport name for diagnostics.

Implements mcp::transport::Transport< Role >.

receive()

core::Result< std::optional< RxMessage > > mcp::transport::StreamableHttpClientTransport::receive ( )

overridevirtual

Receives the next JSON-RPC message from the peer.

receive() is the sequential inbound side. A successful std::nullopt return is an orderly end-of-stream signal, not a parse or transport error.

Implements mcp::transport::Transport< Role >.

send()

core::Result< core::Unit > mcp::transport::StreamableHttpClientTransport::send ( TxMessage  message )

overridevirtual

Sends one JSON-RPC message to the peer.

Concurrency safety is implementation-specific and must be documented by the concrete transport.

Implements mcp::transport::Transport< Role >.

---

The documentation for this class was generated from the following file:

• sdk/transport/include/cxxmcp/transport/http_transport.hpp