kotlin-sdk-client/io.modelcontextprotocol.kotlin.sdk.client/StreamableHttpClientTransport

StreamableHttpClientTransport

class StreamableHttpClientTransport(client: HttpClient, url: String, reconnectionOptions: ReconnectionOptions = ReconnectionOptions(), requestBuilder: HttpRequestBuilder.() -> Unit = {}) : AbstractClientTransport(source)

Client transport for Streamable HTTP: this implements the MCP Streamable HTTP transport specification. It will connect to a server using HTTP POST for sending messages and HTTP GET with Server-Sent Events for receiving messages.

Constructors

constructor(client: HttpClient, url: String, reconnectionOptions: ReconnectionOptions = ReconnectionOptions(), requestBuilder: HttpRequestBuilder.() -> Unit = {})

constructor(client: HttpClient, url: String, reconnectionTime: Duration?, requestBuilder: HttpRequestBuilder.() -> Unit = {})

Properties

protocolVersion

var protocolVersion: String?

MCP protocol version negotiated with the server, or null before connection

sessionId

var sessionId: String?

session identifier assigned by the server after initialization, or null before connection

Functions

open suspend override fun close()

onClose

open override fun onClose(block: () -> Unit)

onError

open override fun onError(block: (Throwable) -> Unit)

onMessage

open override fun onMessage(block: suspend (JSONRPCMessage) -> Unit)

send

suspend fun send(message: JSONRPCMessage, resumptionToken: String?, onResumptionToken: (String) -> Unit? = null)

Sends one or more messages with optional resumption support. This is the main send method that matches the TypeScript implementation.

open suspend override fun send(message: JSONRPCMessage, options: TransportSendOptions?)

start

open suspend override fun start()

terminateSession

suspend fun terminateSession()

Terminates the current session by sending a DELETE request to the server.