chore: fix server documentation for getTask/getTaskResult

Also added taskId convenience overloads.

Author: LucaButBoring

mcp-core/src/main/java/io/modelcontextprotocol/client/McpAsyncClient.java

@@ -1653,7 +1653,7 @@ public Mono<McpSchema.GetTaskResult> getTask(String taskId) {
 	 *
 	 * <p>
 	 * This method mirrors
-	 * {@link io.modelcontextprotocol.server.McpSyncServerExchange#getTaskResult(McpSchema.GetTaskPayloadRequest, TypeRef)},
+	 * {@link io.modelcontextprotocol.server.McpAsyncServerExchange#getTaskResult(McpSchema.GetTaskPayloadRequest, TypeRef)},
 	 * which is used for when the server has initiated a task with the client.
 	 *
 	 * <p>

mcp-core/src/main/java/io/modelcontextprotocol/client/McpSyncClient.java

@@ -542,8 +542,8 @@ public McpSchema.GetTaskResult getTask(McpSchema.GetTaskRequest getTaskRequest)
 	 *
 	 * <p>
 	 * This method mirrors
-	 * {@link io.modelcontextprotocol.server.McpSyncServerExchange#getTask(McpSchema.GetTaskRequest)},
-	 * which is used for when the server has initiated a task with the client.
+	 * {@link io.modelcontextprotocol.server.McpSyncServerExchange#getTask(String)}, which
+	 * is used for when the server has initiated a task with the client.
 	 *
 	 * <p>
 	 * This is a convenience overload that creates a {@link McpSchema.GetTaskRequest} with
@@ -620,7 +620,7 @@ public <T extends McpSchema.ServerTaskPayloadResult> T getTaskResult(
 	 *
 	 * <p>
 	 * This method mirrors
-	 * {@link io.modelcontextprotocol.server.McpSyncServerExchange#getTaskResult(McpSchema.GetTaskPayloadRequest, TypeRef)},
+	 * {@link io.modelcontextprotocol.server.McpSyncServerExchange#getTaskResult(String, TypeRef)},
 	 * which is used for when the server has initiated a task with the client.
 	 *
 	 * <p>

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

@@ -530,10 +530,30 @@ void setMinLoggingLevel(LoggingLevel minLoggingLevel) {
 	// --------------------------
 
 	/**
-	 * Get the status of a task hosted by the client. This is used when the server has
-	 * sent a task-augmented request to the client and needs to poll for status updates.
-	 * @param getTaskRequest The request containing the task ID
-	 * @return A Mono that emits the task status
+	 * Retrieves a task previously initiated by the server with the client.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpAsyncClient#getTask(McpSchema.GetTaskRequest)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * var result = exchange.getTask(GetTaskRequest.builder()
+	 *     .taskId(taskId)
+	 *     .build())
+	 *     .block();
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param getTaskRequest The request containing the task ID.
+	 * @return A Mono that completes with the task information.
+	 * @see McpSchema.GetTaskRequest
+	 * @see McpSchema.GetTaskResult
 	 */
 	public Mono<McpSchema.GetTaskResult> getTask(McpSchema.GetTaskRequest getTaskRequest) {
 		if (this.clientCapabilities == null) {
@@ -547,11 +567,69 @@ public Mono<McpSchema.GetTaskResult> getTask(McpSchema.GetTaskRequest getTaskReq
 	}
 
 	/**
-	 * Get the result of a completed task hosted by the client.
-	 * @param <T> The expected result type
-	 * @param getTaskPayloadRequest The request containing the task ID
-	 * @param resultTypeRef Type reference for deserializing the result
-	 * @return A Mono that emits the task result
+	 * Retrieves a task previously initiated by the server with the client by its ID.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpAsyncClient#getTask(String)}, which is
+	 * used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * This is a convenience overload that creates a {@link McpSchema.GetTaskRequest} with
+	 * the given task ID.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * var result = exchange.getTask(taskId);
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param taskId The task identifier to query.
+	 * @return A Mono that completes with the task status and metadata.
+	 */
+	public Mono<McpSchema.GetTaskResult> getTask(String taskId) {
+		return this.getTask(McpSchema.GetTaskRequest.builder().taskId(taskId).build());
+	}
+
+	/**
+	 * Get the result of a completed task previously initiated by the server with the
+	 * client.
+	 *
+	 * <p>
+	 * The result type depends on the original request that created the task. For sampling
+	 * requests, use {@code new TypeRef<McpSchema.CreateMessageResult>(){}}. For
+	 * elicitation requests, use {@code new TypeRef<McpSchema.ElicitResult>(){}}.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpAsyncClient#getTaskResult(McpSchema.GetTaskPayloadRequest, TypeRef)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * // For sampling task results:
+	 * var result = exchange.getTaskResult(
+	 *     new GetTaskPayloadRequest(taskId, null),
+	 *     new TypeRef<McpSchema.CreateMessageResult>(){})
+	 *     .block();
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param <T> The expected result type, must extend
+	 * {@link McpSchema.ClientTaskPayloadResult}
+	 * @param getTaskPayloadRequest The request containing the task ID.
+	 * @param resultTypeRef Type reference for deserializing the result.
+	 * @return A Mono that completes with the task result.
+	 * @see McpSchema.GetTaskPayloadRequest
+	 * @see McpSchema.ClientTaskPayloadResult
 	 */
 	public <T extends McpSchema.ClientTaskPayloadResult> Mono<T> getTaskResult(
 			McpSchema.GetTaskPayloadRequest getTaskPayloadRequest, TypeRef<T> resultTypeRef) {
@@ -565,6 +643,51 @@ public <T extends McpSchema.ClientTaskPayloadResult> Mono<T> getTaskResult(
 		return this.session.sendRequest(McpSchema.METHOD_TASKS_RESULT, getTaskPayloadRequest, resultTypeRef);
 	}
 
+	/**
+	 * Get the result of a completed task previously initiated by the server with the
+	 * client by its task ID.
+	 *
+	 * <p>
+	 * This is a convenience overload that creates a
+	 * {@link McpSchema.GetTaskPayloadRequest} from the task ID.
+	 *
+	 * <p>
+	 * The result type depends on the original request that created the task. For sampling
+	 * requests, use {@code new TypeRef<McpSchema.CreateMessageResult>(){}}. For
+	 * elicitation requests, use {@code new TypeRef<McpSchema.ElicitResult>(){}}.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpAsyncClient#getTaskResult(String, TypeRef)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * // For sampling task results:
+	 * var result = exchange.getTaskResult(
+	 *     taskId,
+	 *     new TypeRef<McpSchema.CreateMessageResult>(){})
+	 *     .block();
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param <T> The expected result type, must extend
+	 * {@link McpSchema.ClientTaskPayloadResult}
+	 * @param taskId The task identifier.
+	 * @param resultTypeRef Type reference for deserializing the result.
+	 * @return A Mono that completes with the task result.
+	 * @see McpSchema.GetTaskPayloadRequest
+	 * @see McpSchema.ClientTaskPayloadResult
+	 */
+	public <T extends McpSchema.ClientTaskPayloadResult> Mono<T> getTaskResult(String taskId,
+			TypeRef<T> resultTypeRef) {
+		return this.getTaskResult(McpSchema.GetTaskPayloadRequest.builder().taskId(taskId).build(), resultTypeRef);
+	}
+
 	/**
 	 * List all tasks hosted by the client.
 	 *

mcp-core/src/main/java/io/modelcontextprotocol/server/McpSyncServerExchange.java

@@ -212,27 +212,146 @@ public Object ping() {
 	// --------------------------
 
 	/**
-	 * Get the status of a task hosted by the client. This is used when the server has
-	 * sent a task-augmented request to the client and needs to poll for status updates.
-	 * @param getTaskRequest The request containing the task ID
-	 * @return The task status
+	 * Retrieves a task previously initiated by the server with the client.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpSyncClient#getTask(McpSchema.GetTaskRequest)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * var result = exchange.getTask(GetTaskRequest.builder()
+	 *     .taskId(taskId)
+	 *     .build());
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param getTaskRequest The request containing the task ID.
+	 * @return The task information.
+	 * @see McpSchema.GetTaskRequest
+	 * @see McpSchema.GetTaskResult
 	 */
 	public McpSchema.GetTaskResult getTask(McpSchema.GetTaskRequest getTaskRequest) {
 		return this.exchange.getTask(getTaskRequest).block();
 	}
 
 	/**
-	 * Get the result of a completed task hosted by the client.
-	 * @param <T> The expected result type
-	 * @param getTaskPayloadRequest The request containing the task ID
-	 * @param resultTypeRef Type reference for deserializing the result
-	 * @return The task result
+	 * Retrieves a task previously initiated by the server with the client by its ID.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpSyncClient#getTask(String)}, which is used
+	 * for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * This is a convenience overload that creates a {@link McpSchema.GetTaskRequest} with
+	 * the given task ID.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * var result = exchange.getTask(taskId);
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param taskId The task identifier to query.
+	 * @return The task status and metadata.
+	 */
+	public McpSchema.GetTaskResult getTask(String taskId) {
+		return this.exchange.getTask(McpSchema.GetTaskRequest.builder().taskId(taskId).build()).block();
+	}
+
+	/**
+	 * Get the result of a completed task previously initiated by the server with the
+	 * client.
+	 *
+	 * <p>
+	 * The result type depends on the original request that created the task. For sampling
+	 * requests, use {@code new TypeRef<McpSchema.CreateMessageResult>(){}}. For
+	 * elicitation requests, use {@code new TypeRef<McpSchema.ElicitResult>(){}}.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpSyncClient#getTaskResult(McpSchema.GetTaskPayloadRequest, TypeRef)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * // For sampling task results:
+	 * var result = exchange.getTaskResult(
+	 *     new GetTaskPayloadRequest(taskId, null),
+	 *     new TypeRef<McpSchema.CreateMessageResult>(){});
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param <T> The expected result type, must extend
+	 * {@link McpSchema.ClientTaskPayloadResult}
+	 * @param getTaskPayloadRequest The request containing the task ID.
+	 * @param resultTypeRef Type reference for deserializing the result.
+	 * @return The task result.
+	 * @see McpSchema.GetTaskPayloadRequest
+	 * @see McpSchema.ClientTaskPayloadResult
 	 */
 	public <T extends McpSchema.ClientTaskPayloadResult> T getTaskResult(
 			McpSchema.GetTaskPayloadRequest getTaskPayloadRequest, TypeRef<T> resultTypeRef) {
 		return this.exchange.getTaskResult(getTaskPayloadRequest, resultTypeRef).block();
 	}
 
+	/**
+	 * Get the result of a completed task previously initiated by the server with the
+	 * client by its task ID.
+	 *
+	 * <p>
+	 * This is a convenience overload that creates a
+	 * {@link McpSchema.GetTaskPayloadRequest} from the task ID.
+	 *
+	 * <p>
+	 * The result type depends on the original request that created the task. For sampling
+	 * requests, use {@code new TypeRef<McpSchema.CreateMessageResult>(){}}. For
+	 * elicitation requests, use {@code new TypeRef<McpSchema.ElicitResult>(){}}.
+	 *
+	 * <p>
+	 * This method mirrors
+	 * {@link io.modelcontextprotocol.client.McpSyncClient#getTaskResult(String, TypeRef)},
+	 * which is used for when the client has initiated a task with the server.
+	 *
+	 * <p>
+	 * Example usage:
+	 *
+	 * <pre>{@code
+	 * // For sampling task results:
+	 * var result = exchange.getTaskResult(
+	 *     taskId,
+	 *     new TypeRef<McpSchema.CreateMessageResult>(){});
+	 * }</pre>
+	 *
+	 * <p>
+	 * <strong>Note:</strong> This is an experimental feature that may change in future
+	 * releases.
+	 * @param <T> The expected result type, must extend
+	 * {@link McpSchema.ClientTaskPayloadResult}
+	 * @param taskId The task identifier.
+	 * @param resultTypeRef Type reference for deserializing the result.
+	 * @return The task result.
+	 * @see McpSchema.GetTaskPayloadRequest
+	 * @see McpSchema.ClientTaskPayloadResult
+	 */
+	public <T extends McpSchema.ClientTaskPayloadResult> T getTaskResult(String taskId, TypeRef<T> resultTypeRef) {
+		return this.getTaskResult(McpSchema.GetTaskPayloadRequest.builder().taskId(taskId).build(), resultTypeRef);
+	}
+
 	/**
 	 * List all tasks hosted by the client.
 	 *

mcp-core/src/test/java/io/modelcontextprotocol/server/AbstractMcpClientServerIntegrationTests.java

@@ -2573,15 +2573,12 @@ void testClientSideTaskHostingForElicitation(String clientType) throws Interrupt
 	 */
 	private <T extends McpSchema.ClientTaskPayloadResult> Mono<T> pollForTaskCompletion(McpAsyncServerExchange exchange,
 			String taskId, TypeRef<T> resultTypeRef) {
-		return Mono.defer(() -> exchange.getTask(McpSchema.GetTaskRequest.builder().taskId(taskId).build()))
-			.flatMap(task -> {
-				if (task.status().isTerminal()) {
-					return exchange.getTaskResult(McpSchema.GetTaskPayloadRequest.builder().taskId(taskId).build(),
-							resultTypeRef);
-				}
-				return Mono.delay(Duration.ofMillis(100)).then(pollForTaskCompletion(exchange, taskId, resultTypeRef));
-			})
-			.timeout(Duration.ofSeconds(30));
+		return Mono.defer(() -> exchange.getTask(taskId)).flatMap(task -> {
+			if (task.status().isTerminal()) {
+				return exchange.getTaskResult(taskId, resultTypeRef);
+			}
+			return Mono.delay(Duration.ofMillis(100)).then(pollForTaskCompletion(exchange, taskId, resultTypeRef));
+		}).timeout(Duration.ofSeconds(30));
 	}
 
 	/**