http4k-ai-mcp-testing/org.http4k.ai.mcp.testing/TestMcpSender

TestMcpSender

class TestMcpSender(mcpHandler: PolyHandler, connectRequest: Request)(source)

Constructors

constructor(mcpHandler: PolyHandler, connectRequest: Request)

Properties

var sessionId: AtomicReference<SessionId>

Functions

operator fun invoke(input: McpJsonRpcMessage)

operator fun invoke(input: McpJsonRpcRequest): Sequence<SseMessage.Event>

fun lastEvent(): SseMessage.Event

fun nextId(): Int

fun on(type: KClass<out McpJsonRpcRequest>, fn: (SseMessage.Event) -> Unit)

startEventStream

fun startEventStream()

stopEventStream

fun stopEventStream()