WebsocketMcpClient

class WebsocketMcpClient(wsRequest: Request, name: McpEntity = McpEntity.of("http4k-mcp-client"), version: Version = Version.of("0.0.0"), websocketFactory: WebsocketFactory, capabilities: ClientCapabilities = All, protocolVersion: ProtocolVersion = LATEST_VERSION, title: String? = null, defaultTimeout: Duration = Duration.ofSeconds(1)) : AbstractMcpClient(source)

WS connection MCP client.

Note that the internal representation uses an unbounded blocking queue, so clients are required to consume messages using received().

Constructors

Link copied to clipboard
constructor(wsRequest: Request, name: McpEntity = McpEntity.of("http4k-mcp-client"), version: Version = Version.of("0.0.0"), websocketFactory: WebsocketFactory, capabilities: ClientCapabilities = All, protocolVersion: ProtocolVersion = LATEST_VERSION, title: String? = null, defaultTimeout: Duration = Duration.ofSeconds(1))

Properties

Link copied to clipboard
open override val sessionId: SessionId

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun completions(): McpClient.Completions
Link copied to clipboard
Link copied to clipboard
open override fun progress(): McpClient.RequestProgress
Link copied to clipboard
open override fun prompts(): McpClient.Prompts
Link copied to clipboard
open override fun resources(): McpClient.Resources
Link copied to clipboard
open override fun sampling(): McpClient.Sampling
Link copied to clipboard
open override fun start(overrideDefaultTimeout: Duration? = null): McpResult<McpInitialize.Response.Result>
Link copied to clipboard
open fun stop()
Link copied to clipboard
open override fun tasks(): McpClient.Tasks
Link copied to clipboard
open override fun tools(): McpClient.Tools