Address review comments

Signed-off-by: Christian Tzolov <christian.tzolov@broadcom.com>

Author: tzolov

mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java

@@ -288,7 +288,7 @@ else if (mediaType.isCompatibleWith(MediaType.APPLICATION_JSON)) {
 								logger.trace("Received response to POST for session {}", sessionRepresentation);
 								// communicate to caller the message was delivered
 								sink.success();
-								return responseFlux(response);
+								return statelessResponseFlux(message, response);
 							}
 							else {
 								logger.warn("Unknown media type {} returned for POST in session {}", contentType,
@@ -385,17 +385,18 @@ private static String sessionIdOrPlaceholder(McpTransportSession<?> transportSes
 		return transportSession.sessionId().orElse("[missing_session_id]");
 	}
 
-	private Flux<McpSchema.JSONRPCMessage> responseFlux(ClientResponse response) {
+	private Flux<McpSchema.JSONRPCMessage> statelessResponseFlux(McpSchema.JSONRPCMessage sendMessage,
+			ClientResponse response) {
 		return response.bodyToMono(String.class).<Iterable<McpSchema.JSONRPCMessage>>handle((responseMessage, s) -> {
 			try {
-				if (Utils.hasText(responseMessage) && !responseMessage.trim().equals("{}")) {
+				if (sendMessage instanceof McpSchema.JSONRPCNotification && Utils.hasText(responseMessage)) {
+					logger.warn("Notificaiton: {} received non-compliant response: {}", sendMessage, responseMessage);
+				}
+				else {
 					McpSchema.JSONRPCMessage jsonRpcResponse = McpSchema.deserializeJsonRpcMessage(objectMapper,
 							responseMessage);
 					s.next(List.of(jsonRpcResponse));
 				}
-				else {
-					logger.warn("Received empty response message: {}", responseMessage);
-				}
 			}
 			catch (IOException e) {
 				s.error(e);

mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientStreamableHttpTransport.java

@@ -436,19 +436,16 @@ else if (contentType.contains(TEXT_EVENT_STREAM)) {
 					else if (contentType.contains(APPLICATION_JSON)) {
 						messageSink.success();
 						String data = ((ResponseSubscribers.AggregateResponseEvent) responseEvent).data();
-						if (Utils.hasText(data) && !data.trim().equals("{}")) {
+						if (sendMessage instanceof McpSchema.JSONRPCNotification && Utils.hasText(data)) {
+							logger.warn("Notificaiton: {} received non-compliant response: {}", sendMessage, data);
+							return Mono.empty();
+						}
 
-							try {
-								return Mono.just(McpSchema.deserializeJsonRpcMessage(objectMapper, data));
-							}
-							catch (IOException e) {
-								return Mono.error(e);
-							}
+						try {
+							return Mono.just(McpSchema.deserializeJsonRpcMessage(objectMapper, data));
 						}
-						else {
-							// No content type means no response body
-							logger.debug("No content type returned for POST in session {}", sessionRepresentation);
-							return Mono.empty();
+						catch (IOException e) {
+							return Mono.error(e);
 						}
 					}
 					logger.warn("Unknown media type {} returned for POST in session {}", contentType,