WebsocketSessions

class WebsocketSessions(sessionProvider: SessionProvider = SessionProvider.Random(Random), keepAliveDelay: Duration = Duration.ofSeconds(2)) : Sessions<Websocket>

Constructors

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

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

open override fun end(context: ClientRequestContext)

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

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

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

open override fun retrieveSession(connectRequest: Request): SessionState

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