perf(webrx): optimize session broadcasting with Flux.fromIterable (modelcontextprotocol#109)

Author: noear

mcp-solon/mcp-solon-webrx/src/main/java/io/modelcontextprotocol/server/transport/WebRxSseServerTransportProvider.java

@@ -184,10 +184,9 @@ public Mono<Void> notifyClients(String method, Object params) {
 
 		logger.debug("Attempting to broadcast message to {} active sessions", sessions.size());
 
-		return Flux.fromStream(sessions.values().stream())
+		return Flux.fromIterable(sessions.values())
 				.flatMap(session -> session.sendNotification(method, params)
-						.doOnError(e -> logger.error("Failed to " + "send message to session " + "{}: {}", session.getId(),
-								e.getMessage()))
+						.doOnError(e -> logger.error("Failed to send message to session {}: {}", session.getId(), e.getMessage()))
 						.onErrorComplete())
 				.then();
 	}