MCP Kotlin SDK/org.jetbrains.kotlinx.mcp.client/SSEClientTransport

SSEClientTransport

class SSEClientTransport(client: HttpClient, urlString: String?, reconnectionTime: Duration? = null, requestBuilder: HttpRequestBuilder.() -> Unit = {}) : Transport(source)

Client transport for SSE: this will connect to a server using Server-Sent Events for receiving messages and make separate POST requests for sending messages.

Constructors

SSEClientTransport

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

Properties

open override var onClose: () -> Unit?

Callback for when the connection is closed for any reason.

open override var onError: (Throwable) -> Unit?

Callback for when an error occurs.

open override var onMessage: suspend (JSONRPCMessage) -> Unit?

Callback for when a message (request or response) is received over the connection.

Functions

open suspend override fun close()

Closes the connection.

open suspend override fun send(message: JSONRPCMessage)

Sends a JSON-RPC message (request or response).

open suspend override fun start()

Starts processing messages on the transport, including any connection steps that might need to be taken.