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))
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun start(overrideDefaultTimeout: Duration? = null): McpResult<McpInitialize.Response.Result>
Link copied to clipboard
Link copied to clipboard