kotlin-sdk-server/io.modelcontextprotocol.kotlin.sdk.server/SseServerTransport

SseServerTransport

class SseServerTransport(endpoint: String, session: ServerSSESession) : AbstractTransport(source)

Server transport for SSE: this will send messages over an SSE connection and receive messages from HTTP POST requests.

Creates a new SSE server transport, which will direct the client to POST messages to the relative or absolute URL identified by _endpoint.

Constructors

SseServerTransport

constructor(endpoint: String, session: ServerSSESession)

Properties

sessionId

val sessionId: String

unique identifier for this transport session, generated randomly on creation

Functions

open suspend override fun close()

handleMessage

suspend fun handleMessage(message: String)

Handle a client message, regardless of how it arrived. This can be used to inform the server of messages that arrive via a means different from HTTP POST.

handlePostMessage

suspend fun handlePostMessage(call: ApplicationCall)

Handles incoming POST messages.

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

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

start

open suspend override fun start()

Handles the initial SSE connection request.