From dbb4486a47c475c60d6647839ea78d6b766bb590 Mon Sep 17 00:00:00 2001
From: jitokim <pigberger70@gmail.com>
Date: Sun, 6 Apr 2025 02:12:34 +0900
Subject: [PATCH] replace Flux.fromStream with lux.fromIterable

Signed-off-by: jitokim <pigberger70@gmail.com>
---
 .../server/transport/WebFluxSseServerTransportProvider.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java
index 85a39a82f..af2ff06a3 100644
--- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java
+++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java
@@ -171,10 +171,10 @@ public Mono<Void> notifyClients(String method, Map<String, 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();
 	}