Update examples

Author: tiginamaria

kotlin-sdk-server/api/kotlin-sdk-server.api

@@ -1,3 +1,7 @@
+public final class io/modelcontextprotocol/kotlin/sdk/LibVersionKt {
+	public static final field LIB_VERSION Ljava/lang/String;
+}
+
 public final class io/modelcontextprotocol/kotlin/sdk/server/KtorServerKt {
 	public static final fun MCP (Lio/ktor/server/application/Application;Lkotlin/jvm/functions/Function1;)V
 	public static final fun mcp (Lio/ktor/server/application/Application;Lkotlin/jvm/functions/Function1;)V

samples/kotlin-mcp-server/src/commonMain/kotlin/server.kt

@@ -23,6 +23,7 @@ import io.modelcontextprotocol.kotlin.sdk.TextResourceContents
 import io.modelcontextprotocol.kotlin.sdk.Tool
 import io.modelcontextprotocol.kotlin.sdk.server.Server
 import io.modelcontextprotocol.kotlin.sdk.server.ServerOptions
+import io.modelcontextprotocol.kotlin.sdk.server.ServerSession
 import io.modelcontextprotocol.kotlin.sdk.server.SseServerTransport
 import io.modelcontextprotocol.kotlin.sdk.server.mcp
 
@@ -94,33 +95,33 @@ fun configureServer(): Server {
 }
 
 suspend fun runSseMcpServerWithPlainConfiguration(port: Int) {
-    val servers = ConcurrentMap<String, Server>()
+    val serverSessions = ConcurrentMap<String, ServerSession>()
     println("Starting sse server on port $port. ")
     println("Use inspector to connect to the http://localhost:$port/sse")
 
+    val server = configureServer()
+
     embeddedServer(CIO, host = "0.0.0.0", port = port) {
         install(SSE)
         routing {
             sse("/sse") {
                 val transport = SseServerTransport("/message", this)
-                val server = configureServer()
 
                 // For SSE, you can also add prompts/tools/resources if needed:
                 // server.addTool(...), server.addPrompt(...), server.addResource(...)
 
-                servers[transport.sessionId] = server
+                val serverSession = server.connect(transport)
+                serverSessions[transport.sessionId] = server.connect(transport)
 
-                server.onClose {
+                serverSession.onClose {
                     println("Server closed")
-                    servers.remove(transport.sessionId)
+                    serverSessions.remove(transport.sessionId)
                 }
-
-                server.connect(transport)
             }
             post("/message") {
                 println("Received Message")
                 val sessionId: String = call.request.queryParameters["sessionId"]!!
-                val transport = servers[sessionId]?.transport as? SseServerTransport
+                val transport = serverSessions[sessionId]?.transport as? SseServerTransport
                 if (transport == null) {
                     call.respond(HttpStatusCode.NotFound, "Session not found")
                     return@post

samples/weather-stdio-server/src/main/kotlin/io/modelcontextprotocol/sample/server/McpWeatherServer.kt

@@ -114,9 +114,9 @@ fun `run mcp server`() {
     )
 
     runBlocking {
-        server.connect(transport)
+        val session = server.connect(transport)
         val done = Job()
-        server.onClose {
+        session.onClose {
             done.complete()
         }
         done.join()