Add client side list handlers to handle pagination

Add client side list handlers to handle pagination for prompts,
resources and resource templates.

Author: pantanurag555

mcp-test/src/main/java/io/modelcontextprotocol/client/AbstractMcpAsyncClientTests.java

@@ -162,6 +162,23 @@ void testListTools() {
 		});
 	}
 
+	@Test
+	void testListAllTools() {
+		withClient(createMcpTransport(), mcpAsyncClient -> {
+			StepVerifier.create(mcpAsyncClient.initialize().then(mcpAsyncClient.listAllTools()))
+				.consumeNextWith(tools -> {
+					assertThat(tools).isNotNull().satisfies(result -> {
+						assertThat(result).isNotEmpty();
+
+						Tool firstTool = result.get(0);
+						assertThat(firstTool.name()).isNotNull();
+						assertThat(firstTool.description()).isNotNull();
+					});
+				})
+				.verifyComplete();
+		});
+	}
+
 	@Test
 	void testPingWithoutInitialization() {
 		verifyCallSucceedsWithImplicitInitialization(client -> client.ping(), "pinging the server");
@@ -293,6 +310,23 @@ void testListResources() {
 		});
 	}
 
+	@Test
+	void testListAllResources() {
+		withClient(createMcpTransport(), mcpAsyncClient -> {
+			StepVerifier.create(mcpAsyncClient.initialize().then(mcpAsyncClient.listAllResources()))
+				.consumeNextWith(resources -> {
+					assertThat(resources).isNotNull().satisfies(result -> {
+						assertThat(result).isNotEmpty();
+
+						Resource firstResource = result.get(0);
+						assertThat(firstResource.uri()).isNotNull();
+						assertThat(firstResource.name()).isNotNull();
+					});
+				})
+				.verifyComplete();
+		});
+	}
+
 	@Test
 	void testMcpAsyncClientState() {
 		withClient(createMcpTransport(), mcpAsyncClient -> {
@@ -324,6 +358,23 @@ void testListPrompts() {
 		});
 	}
 
+	@Test
+	void testListAllPrompts() {
+		withClient(createMcpTransport(), mcpAsyncClient -> {
+			StepVerifier.create(mcpAsyncClient.initialize().then(mcpAsyncClient.listAllPrompts()))
+				.consumeNextWith(prompts -> {
+					assertThat(prompts).isNotNull().satisfies(result -> {
+						assertThat(result).isNotEmpty();
+
+						Prompt firstPrompt = result.get(0);
+						assertThat(firstPrompt.name()).isNotNull();
+						assertThat(firstPrompt.description()).isNotNull();
+					});
+				})
+				.verifyComplete();
+		});
+	}
+
 	@Test
 	void testGetPromptWithoutInitialization() {
 		GetPromptRequest request = new GetPromptRequest("simple_prompt", Map.of());
@@ -439,6 +490,23 @@ void testListResourceTemplates() {
 		});
 	}
 
+	@Test
+	void testListAllResourceTemplates() {
+		withClient(createMcpTransport(), mcpAsyncClient -> {
+			StepVerifier.create(mcpAsyncClient.initialize().then(mcpAsyncClient.listAllResourceTemplates()))
+				.consumeNextWith(resourceTemplates -> {
+					assertThat(resourceTemplates).isNotNull().satisfies(result -> {
+						assertThat(result).isNotEmpty();
+
+						McpSchema.ResourceTemplate firstResourceTemplate = result.get(0);
+						assertThat(firstResourceTemplate.name()).isNotNull();
+						assertThat(firstResourceTemplate.description()).isNotNull();
+					});
+				})
+				.verifyComplete();
+		});
+	}
+
 	// @Test
 	void testResourceSubscription() {
 		withClient(createMcpTransport(), mcpAsyncClient -> {

mcp-test/src/main/java/io/modelcontextprotocol/client/AbstractMcpSyncClientTests.java

@@ -161,6 +161,22 @@ void testListTools() {
 		});
 	}
 
+	@Test
+	void testListAllTools() {
+		withClient(createMcpTransport(), mcpSyncClient -> {
+			mcpSyncClient.initialize();
+			List<Tool> tools = mcpSyncClient.listAllTools();
+
+			assertThat(tools).isNotNull().satisfies(result -> {
+				assertThat(result).isNotEmpty();
+
+				Tool firstTool = result.get(0);
+				assertThat(firstTool.name()).isNotNull();
+				assertThat(firstTool.description()).isNotNull();
+			});
+		});
+	}
+
 	@Test
 	void testCallToolsWithoutInitialization() {
 		verifyCallSucceedsWithImplicitInitialization(
@@ -320,6 +336,22 @@ void testListResources() {
 		});
 	}
 
+	@Test
+	void testListAllResources() {
+		withClient(createMcpTransport(), mcpSyncClient -> {
+			mcpSyncClient.initialize();
+			List<Resource> resources = mcpSyncClient.listAllResources();
+
+			assertThat(resources).isNotNull().satisfies(result -> {
+				assertThat(result).isNotEmpty();
+
+				Resource firstResource = result.get(0);
+				assertThat(firstResource.uri()).isNotNull();
+				assertThat(firstResource.name()).isNotNull();
+			});
+		});
+	}
+
 	@Test
 	void testClientSessionState() {
 		withClient(createMcpTransport(), mcpSyncClient -> {
@@ -418,6 +450,22 @@ void testListResourceTemplates() {
 		});
 	}
 
+	@Test
+	void testListAllResourceTemplates() {
+		withClient(createMcpTransport(), mcpSyncClient -> {
+			mcpSyncClient.initialize();
+			List<McpSchema.ResourceTemplate> resourceTemplates = mcpSyncClient.listAllResourceTemplates();
+
+			assertThat(resourceTemplates).isNotNull().satisfies(result -> {
+				assertThat(result).isNotEmpty();
+
+				McpSchema.ResourceTemplate firstResourceTemplate = result.get(0);
+				assertThat(firstResourceTemplate.name()).isNotNull();
+				assertThat(firstResourceTemplate.description()).isNotNull();
+			});
+		});
+	}
+
 	// @Test
 	void testResourceSubscription() {
 		withClient(createMcpTransport(), mcpSyncClient -> {

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

@@ -13,7 +13,11 @@
 import java.util.function.Function;
 import java.util.function.Supplier;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.fasterxml.jackson.core.type.TypeReference;
+
 import io.modelcontextprotocol.spec.McpClientSession;
 import io.modelcontextprotocol.spec.McpClientSession.NotificationHandler;
 import io.modelcontextprotocol.spec.McpClientSession.RequestHandler;
@@ -35,8 +39,6 @@
 import io.modelcontextprotocol.spec.McpTransportSessionNotFoundException;
 import io.modelcontextprotocol.util.Assert;
 import io.modelcontextprotocol.util.Utils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Sinks;
@@ -656,7 +658,7 @@ public Mono<McpSchema.CallToolResult> callTool(McpSchema.CallToolRequest callToo
 	}
 
 	/**
-	 * Retrieves the list of all tools provided by the server.
+	 * Retrieves the first page of tools provided by the server.
 	 * @return A Mono that emits the list of tools result.
 	 */
 	public Mono<McpSchema.ListToolsResult> listTools() {
@@ -679,18 +681,26 @@ public Mono<McpSchema.ListToolsResult> listTools(String cursor) {
 		});
 	}
 
-	private NotificationHandler asyncToolsChangeNotificationHandler(
-			List<Function<List<McpSchema.Tool>, Mono<Void>>> toolsChangeConsumers) {
-		// TODO: params are not used yet
-		return params -> this.listTools().expand(result -> {
+	/**
+	 * Retrieves list of all tools provided by the server after handling pagination.
+	 * @return A Mono that emits a list of all tools
+	 */
+	public Mono<List<McpSchema.Tool>> listAllTools() {
+		return this.listTools().expand(result -> {
 			if (result.nextCursor() != null) {
 				return this.listTools(result.nextCursor());
 			}
 			return Mono.empty();
-		}).reduce(new ArrayList<McpSchema.Tool>(), (allTools, result) -> {
+		}).reduce(new ArrayList<>(), (allTools, result) -> {
 			allTools.addAll(result.tools());
 			return allTools;
-		})
+		});
+	}
+
+	private NotificationHandler asyncToolsChangeNotificationHandler(
+			List<Function<List<McpSchema.Tool>, Mono<Void>>> toolsChangeConsumers) {
+		// TODO: params are not used yet
+		return params -> this.listAllTools()
 			.flatMap(allTools -> Flux.fromIterable(toolsChangeConsumers)
 				.flatMap(consumer -> consumer.apply(allTools))
 				.onErrorResume(error -> {
@@ -714,9 +724,9 @@ private NotificationHandler asyncToolsChangeNotificationHandler(
 	};
 
 	/**
-	 * Retrieves the list of all resources provided by the server. Resources represent any
-	 * kind of UTF-8 encoded data that an MCP server makes available to clients, such as
-	 * database records, API responses, log files, and more.
+	 * Retrieves the first page of resources provided by the server. Resources represent
+	 * any kind of UTF-8 encoded data that an MCP server makes available to clients, such
+	 * as database records, API responses, log files, and more.
 	 * @return A Mono that completes with the list of resources result.
 	 * @see McpSchema.ListResourcesResult
 	 * @see #readResource(McpSchema.Resource)
@@ -745,6 +755,26 @@ public Mono<McpSchema.ListResourcesResult> listResources(String cursor) {
 		});
 	}
 
+	/**
+	 * Retrieves the list of all resources provided by the server. Resources represent any
+	 * kind of UTF-8 encoded data that an MCP server makes available to clients, such as
+	 * database records, API responses, log files, and more.
+	 * @return A Mono that completes with list of all resources.
+	 * @see McpSchema.Resource
+	 * @see #readResource(McpSchema.Resource)
+	 */
+	public Mono<List<McpSchema.Resource>> listAllResources() {
+		return this.listResources().expand(result -> {
+			if (result.nextCursor() != null) {
+				return this.listResources(result.nextCursor());
+			}
+			return Mono.empty();
+		}).reduce(new ArrayList<>(), (allResources, result) -> {
+			allResources.addAll(result.resources());
+			return allResources;
+		});
+	}
+
 	/**
 	 * Reads the content of a specific resource identified by the provided Resource
 	 * object. This method fetches the actual data that the resource represents.
@@ -777,7 +807,7 @@ public Mono<McpSchema.ReadResourceResult> readResource(McpSchema.ReadResourceReq
 	}
 
 	/**
-	 * Retrieves the list of all resource templates provided by the server. Resource
+	 * Retrieves the first page of resource templates provided by the server. Resource
 	 * templates allow servers to expose parameterized resources using URI templates,
 	 * enabling dynamic resource access based on variable parameters.
 	 * @return A Mono that completes with the list of resource templates result.
@@ -806,6 +836,25 @@ public Mono<McpSchema.ListResourceTemplatesResult> listResourceTemplates(String
 		});
 	}
 
+	/**
+	 * Retrieves the list of all resource templates provided by the server. Resource
+	 * templates allow servers to expose parameterized resources using URI templates,
+	 * enabling dynamic resource access based on variable parameters.
+	 * @return A Mono that completes with the list of all resource templates.
+	 * @see McpSchema.ResourceTemplate
+	 */
+	public Mono<List<McpSchema.ResourceTemplate>> listAllResourceTemplates() {
+		return this.listResourceTemplates().expand(result -> {
+			if (result.nextCursor() != null) {
+				return this.listResourceTemplates(result.nextCursor());
+			}
+			return Mono.empty();
+		}).reduce(new ArrayList<>(), (allResourceTemplates, result) -> {
+			allResourceTemplates.addAll(result.resourceTemplates());
+			return allResourceTemplates;
+		});
+	}
+
 	/**
 	 * Subscribes to changes in a specific resource. When the resource changes on the
 	 * server, the client will receive notifications through the resources change
@@ -855,7 +904,7 @@ private NotificationHandler asyncResourcesChangeNotificationHandler(
 	};
 
 	/**
-	 * Retrieves the list of all prompts provided by the server.
+	 * Retrieves the first page of prompts provided by the server.
 	 * @return A Mono that completes with the list of prompts result.
 	 * @see McpSchema.ListPromptsResult
 	 * @see #getPrompt(GetPromptRequest)
@@ -876,6 +925,24 @@ public Mono<ListPromptsResult> listPrompts(String cursor) {
 			.sendRequest(McpSchema.METHOD_PROMPT_LIST, new PaginatedRequest(cursor), LIST_PROMPTS_RESULT_TYPE_REF));
 	}
 
+	/**
+	 * Retrieves the list of all prompts provided by the server.
+	 * @return A Mono that completes with the list of all prompts.
+	 * @see McpSchema.Prompt
+	 * @see #getPrompt(GetPromptRequest)
+	 */
+	public Mono<List<McpSchema.Prompt>> listAllPrompts() {
+		return this.listPrompts().expand(result -> {
+			if (result.nextCursor() != null) {
+				return this.listPrompts(result.nextCursor());
+			}
+			return Mono.empty();
+		}).reduce(new ArrayList<>(), (allPrompts, result) -> {
+			allPrompts.addAll(result.prompts());
+			return allPrompts;
+		});
+	}
+
 	/**
 	 * Retrieves a specific prompt by its ID. This provides the complete prompt template
 	 * including all parameters and instructions for generating AI content.