kotlin-sdk-core/io.modelcontextprotocol.kotlin.sdk.shared/AbstractTransport

AbstractTransport

abstract class AbstractTransport : Transport(source)

Base class for Transport implementations that handles the bookkeeping for onClose, onError and onMessage callback registration, exposing the composed callbacks to subclasses for invocation.

The callbacks are composed: each call to onClose, onError, or onMessage chains the new block after any previously registered ones.

Inheritors

AbstractClientTransport

WebSocketMcpTransport

Constructors

AbstractTransport

constructor()

Functions

abstract suspend fun close()

Closes the transport.

onClose

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

Callback for when the connection is closed for any reason.

onError

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

Callback for when an error occurs.

onMessage

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

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

send

abstract suspend fun send(message: JSONRPCMessage, options: TransportSendOptions? = null)

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

start

abstract suspend fun start()

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