http4k-ai-mcp-sdk/org.http4k.ai.mcp.server.websocket/WebsocketSessions

WebsocketSessions

class WebsocketSessions(sessionProvider: SessionProvider = SessionProvider.Random(), sessionEventTracking: SessionEventTracking = SessionEventTracking.InMemory(), eventStore: SessionEventStore = InMemory(100), keepAliveDelay: Duration = Duration.ofSeconds(2)) : Sessions<Websocket> (source)

Constructors

WebsocketSessions

constructor(sessionProvider: SessionProvider = SessionProvider.Random(), sessionEventTracking: SessionEventTracking = SessionEventTracking.InMemory(), eventStore: SessionEventStore = InMemory(100), keepAliveDelay: Duration = Duration.ofSeconds(2))

Functions

assign

open override fun assign(context: ClientRequestContext, transport: Websocket, connectRequest: Request)

end

open override fun end(context: ClientRequestContext)

onClose

open override fun onClose(context: ClientRequestContext, fn: () -> Unit)

retrieveSession

open override fun retrieveSession(connectRequest: Request): McpSessionState

send

open override fun send(context: ClientRequestContext, message: McpJsonRpcMessage)

start

fun start(executor: SimpleScheduler = SimpleSchedulerService(1)): ScheduledFuture<*>

transportFor

open override fun transportFor(context: ClientRequestContext): Websocket