Skip to content

Commit f239a44

Browse files
author
Ajay Kannan
committed
---
yaml --- r: 3601 b: refs/heads/pubsub-alpha c: 6b322fa h: refs/heads/master i: 3599: 9e5a77b
1 parent 9c18659 commit f239a44

4 files changed

Lines changed: 17 additions & 10 deletions

File tree

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
refs/heads/master: 36a62ef856d199f8efd09501b5ba65c422c01f23
33
refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
44
refs/heads/gh-pages: 7406918e071dd2c5677a638ae2a06e7592b6542c
5-
refs/heads/pubsub-alpha: 1f6a7b3f07fbfb8f9cfdfb7cc83c13f32577c1f4
5+
refs/heads/pubsub-alpha: 6b322fa1a0cacb7c79b1709df78fe6163d48ce07
66
refs/heads/update-datastore: 47aae517c2cb33f1dccd909adaced73ec9d0f4df
77
refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
88
refs/tags/v0.0.10: 207ebd2a3472fddee69fe1298eb90429e3306efd

branches/pubsub-alpha/gcloud-java-resourcemanager/src/main/java/com/google/gcloud/resourcemanager/testing/LocalResourceManagerHelper.java

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,9 @@ private static Map<String, Object> parseListOptions(String query) {
248248
options.put("pageToken", argEntry[1]);
249249
break;
250250
case "pageSize":
251-
options.put("pageSize", Integer.parseInt(argEntry[1]));
251+
int pageSize = Integer.valueOf(argEntry[1]);
252+
checkArgument(pageSize > 0, "Page size must be greater than 0.");
253+
options.put("pageSize", pageSize);
252254
break;
253255
}
254256
}
@@ -363,10 +365,11 @@ Response list(Map<String, Object> options) {
363365
String pageToken = (String) options.get("pageToken");
364366
Integer pageSize = (Integer) options.get("pageSize");
365367
String nextPageToken = null;
366-
for (Project p : projects.values()) {
367-
if (pageToken != null && p.getProjectId().compareTo(pageToken) < 0) {
368-
continue;
369-
}
368+
Map<String, Project> projectsToScan = projects;
369+
if (pageToken != null) {
370+
projectsToScan = projects.tailMap(pageToken);
371+
}
372+
for (Project p : projectsToScan.values()) {
370373
if (pageSize != null && count >= pageSize) {
371374
nextPageToken = p.getProjectId();
372375
break;
@@ -385,11 +388,13 @@ Response list(Map<String, Object> options) {
385388
StringBuilder responseBody = new StringBuilder();
386389
responseBody.append("{\"projects\": [");
387390
Joiner.on(",").appendTo(responseBody, projectsSerialized);
388-
responseBody.append("]");
391+
responseBody.append(']');
389392
if (nextPageToken != null) {
390-
responseBody.append(", \"nextPageToken\": \"" + nextPageToken + "\"");
393+
responseBody.append(", \"nextPageToken\": \"");
394+
responseBody.append(nextPageToken);
395+
responseBody.append('"');
391396
}
392-
responseBody.append("}");
397+
responseBody.append('}');
393398
return new Response(HTTP_OK, responseBody.toString());
394399
}
395400

branches/pubsub-alpha/gcloud-java-resourcemanager/src/test/java/com/google/gcloud/resourcemanager/LocalResourceManagerHelperTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -316,6 +316,7 @@ public void testListPaging() {
316316
iterator = projects.y().iterator();
317317
compareReadWriteFields(PARTIAL_PROJECT, iterator.next());
318318
assertFalse(iterator.hasNext());
319+
assertNull(projects.x());
319320
}
320321

321322
@Test

branches/pubsub-alpha/gcloud-java-resourcemanager/src/test/java/com/google/gcloud/resourcemanager/ResourceManagerImplTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,7 @@ public void testList() {
183183
}
184184

185185
@Test
186-
public void tsetListPaging() {
186+
public void testListPaging() {
187187
RESOURCE_MANAGER.create(PARTIAL_PROJECT);
188188
RESOURCE_MANAGER.create(COMPLETE_PROJECT);
189189
Page<Project> page = RESOURCE_MANAGER.list(ProjectListOption.pageSize(1));
@@ -195,6 +195,7 @@ public void tsetListPaging() {
195195
iterator = page.values().iterator();
196196
compareReadWriteFields(PARTIAL_PROJECT, iterator.next());
197197
assertFalse(iterator.hasNext());
198+
assertNull(page.nextPageCursor());
198199
}
199200

200201
@Test

0 commit comments

Comments
 (0)