chore: Apply formatter

Author: denniskawurek

mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStreamableServerTransportProvider.java

@@ -273,14 +273,14 @@ else if (message instanceof McpSchema.JSONRPCRequest jsonrpcRequest) {
 							Mono<Void> stream = session.responseStream(jsonrpcRequest, st);
 							Disposable streamSubscription = stream.onErrorComplete(err -> {
 								if (err instanceof McpParamsValidationError) {
-									var errorResponse = new McpSchema.JSONRPCResponse(McpSchema.JSONRPC_VERSION, jsonrpcRequest.id(),
-											null, new McpSchema.JSONRPCResponse.JSONRPCError(McpSchema.ErrorCodes.INVALID_PARAMS,
-											err.getMessage(), null));
+									var errorResponse = new McpSchema.JSONRPCResponse(McpSchema.JSONRPC_VERSION,
+											jsonrpcRequest.id(), null, new McpSchema.JSONRPCResponse.JSONRPCError(
+													McpSchema.ErrorCodes.INVALID_PARAMS, err.getMessage(), null));
 
 									var event = ServerSentEvent.builder()
-											.event(MESSAGE_EVENT_TYPE)
-											.data(errorResponse)
-											.build();
+										.event(MESSAGE_EVENT_TYPE)
+										.data(errorResponse)
+										.build();
 
 									sink.next(event);
 									return true;

mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcStreamableServerTransportProvider.java

@@ -389,11 +389,14 @@ else if (message instanceof McpSchema.JSONRPCRequest jsonrpcRequest) {
 						session.responseStream(jsonrpcRequest, sessionTransport)
 							.contextWrite(ctx -> ctx.put(McpTransportContext.KEY, transportContext))
 							.block();
-					} catch (McpParamsValidationError e) {
-						var errorResponse = new McpSchema.JSONRPCResponse(McpSchema.JSONRPC_VERSION, jsonrpcRequest.id(), null,
-								new McpSchema.JSONRPCResponse.JSONRPCError(McpSchema.ErrorCodes.INVALID_PARAMS, e.getMessage(), null));
+					}
+					catch (McpParamsValidationError e) {
+						var errorResponse = new McpSchema.JSONRPCResponse(McpSchema.JSONRPC_VERSION,
+								jsonrpcRequest.id(), null, new McpSchema.JSONRPCResponse.JSONRPCError(
+										McpSchema.ErrorCodes.INVALID_PARAMS, e.getMessage(), null));
 						sessionTransport.sendMessage(errorResponse).block();
-					} catch (Exception e) {
+					}
+					catch (Exception e) {
 						logger.error("Failed to handle request stream: {}", e.getMessage());
 						sseBuilder.error(e);
 					}