Formatting

Signed-off-by: Dariusz Jędrzejczyk <dariusz.jedrzejczyk@broadcom.com>

Author: chemicL

mcp/src/main/java/io/modelcontextprotocol/server/McpAsyncServer.java

@@ -127,8 +127,8 @@ public class McpAsyncServer {
 	 * @param objectMapper The ObjectMapper to use for JSON serialization/deserialization
 	 */
 	McpAsyncServer(McpServerTransportProvider mcpTransportProvider, ObjectMapper objectMapper,
-				   McpServerFeatures.Async features, Duration requestTimeout,
-				   McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator) {
+			McpServerFeatures.Async features, Duration requestTimeout,
+			McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator) {
 		this.mcpTransportProvider = mcpTransportProvider;
 		this.objectMapper = objectMapper;
 		this.serverInfo = features.serverInfo();
@@ -151,8 +151,8 @@ public class McpAsyncServer {
 	}
 
 	McpAsyncServer(McpStreamableServerTransportProvider mcpTransportProvider, ObjectMapper objectMapper,
-				   McpServerFeatures.Async features, Duration requestTimeout,
-				   McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator) {
+			McpServerFeatures.Async features, Duration requestTimeout,
+			McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator) {
 		this.mcpTransportProvider = mcpTransportProvider;
 		this.objectMapper = objectMapper;
 		this.serverInfo = features.serverInfo();
@@ -169,7 +169,8 @@ public class McpAsyncServer {
 		Map<String, McpRequestHandler<?>> requestHandlers = prepareRequestHandlers();
 		Map<String, McpNotificationHandler> notificationHandlers = prepareNotificationHandlers(features);
 
-		mcpTransportProvider.setSessionFactory(new DefaultMcpStreamableServerSessionFactory(requestTimeout, this::asyncInitializeRequestHandler, requestHandlers, notificationHandlers));
+		mcpTransportProvider.setSessionFactory(new DefaultMcpStreamableServerSessionFactory(requestTimeout,
+				this::asyncInitializeRequestHandler, requestHandlers, notificationHandlers));
 	}
 
 	private Map<String, McpNotificationHandler> prepareNotificationHandlers(McpServerFeatures.Async features) {

mcp/src/main/java/io/modelcontextprotocol/server/McpAsyncServerExchange.java

@@ -57,7 +57,7 @@ public class McpAsyncServerExchange {
 	 * @param clientInfo The client implementation information.
 	 */
 	public McpAsyncServerExchange(McpSession session, McpSchema.ClientCapabilities clientCapabilities,
-								  McpSchema.Implementation clientInfo) {
+			McpSchema.Implementation clientInfo) {
 		this.session = session;
 		this.clientCapabilities = clientCapabilities;
 		this.clientInfo = clientInfo;
@@ -69,11 +69,12 @@ public McpAsyncServerExchange(McpSession session, McpSchema.ClientCapabilities c
 	 * @param session The server session representing a 1-1 interaction.
 	 * @param clientCapabilities The client capabilities that define the supported
 	 * features and functionality.
-	 * @param transportContext context associated with the client as extracted from the transport
+	 * @param transportContext context associated with the client as extracted from the
+	 * transport
 	 * @param clientInfo The client implementation information.
 	 */
 	public McpAsyncServerExchange(McpSession session, McpSchema.ClientCapabilities clientCapabilities,
-								  McpSchema.Implementation clientInfo, McpTransportContext transportContext) {
+			McpSchema.Implementation clientInfo, McpTransportContext transportContext) {
 		this.session = session;
 		this.clientCapabilities = clientCapabilities;
 		this.clientInfo = clientInfo;

mcp/src/main/java/io/modelcontextprotocol/server/McpInitRequestHandler.java

@@ -8,12 +8,11 @@
  */
 public interface McpInitRequestHandler {
 
-    /**
-     * Handles the initialization request.
-     *
-     * @param initializeRequest the initialization request by the client
-     * @return a Mono that will emit the result of the initialization
-     */
-    Mono<McpSchema.InitializeResult> handle(McpSchema.InitializeRequest initializeRequest);
+	/**
+	 * Handles the initialization request.
+	 * @param initializeRequest the initialization request by the client
+	 * @return a Mono that will emit the result of the initialization
+	 */
+	Mono<McpSchema.InitializeResult> handle(McpSchema.InitializeRequest initializeRequest);
 
 }

mcp/src/main/java/io/modelcontextprotocol/server/McpNotificationHandler.java

@@ -7,14 +7,13 @@
  */
 public interface McpNotificationHandler {
 
-    /**
-     * Handles a notification from the client.
-     *
-     * @param exchange the exchange associated with the client that allows calling
-     *                 back to the connected client or inspecting its capabilities.
-     * @param params   the parameters of the notification.
-     * @return a Mono that completes once the notification is handled.
-     */
-    Mono<Void> handle(McpAsyncServerExchange exchange, Object params);
+	/**
+	 * Handles a notification from the client.
+	 * @param exchange the exchange associated with the client that allows calling back to
+	 * the connected client or inspecting its capabilities.
+	 * @param params the parameters of the notification.
+	 * @return a Mono that completes once the notification is handled.
+	 */
+	Mono<Void> handle(McpAsyncServerExchange exchange, Object params);
 
 }

mcp/src/main/java/io/modelcontextprotocol/server/McpRequestHandler.java

@@ -6,18 +6,17 @@
  * A handler for client-initiated requests.
  *
  * @param <T> the type of the response that is expected as a result of handling the
- *            request.
+ * request.
  */
 public interface McpRequestHandler<T> {
 
-    /**
-     * Handles a request from the client.
-     *
-     * @param exchange the exchange associated with the client that allows calling
-     *                 back to the connected client or inspecting its capabilities.
-     * @param params   the parameters of the request.
-     * @return a Mono that will emit the response to the request.
-     */
-    Mono<T> handle(McpAsyncServerExchange exchange, Object params);
+	/**
+	 * Handles a request from the client.
+	 * @param exchange the exchange associated with the client that allows calling back to
+	 * the connected client or inspecting its capabilities.
+	 * @param params the parameters of the request.
+	 * @return a Mono that will emit the response to the request.
+	 */
+	Mono<T> handle(McpAsyncServerExchange exchange, Object params);
 
 }