http4k-mcp-sdk/org.http4k.mcp.server.sse/SseSessions

SseSessions

class SseSessions(sessionProvider: SessionProvider = SessionProvider.Random(Random), sessionEventTracking: SessionEventTracking = SessionEventTracking.InMemory(), keepAliveDelay: Duration = Duration.ofSeconds(2)) : Sessions<Sse>

Constructors

SseSessions

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

Functions

assign

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

end

open override fun end(context: ClientRequestContext)

onClose

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

request

open override fun request(context: ClientRequestContext, message: McpNodeType)

respond

open override fun respond(transport: Sse, session: Session, message: McpNodeType): Result4k<McpNodeType, McpNodeType>

retrieveSession

open override fun retrieveSession(connectRequest: Request): SessionState

start

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

transportFor

open override fun transportFor(context: ClientRequestContext): Sse