This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5ca1f0f8a1801788ba6b2bf7b4b30a2bce6910ae Merge: 1b0f6d7 33f8f86 Author: Ismaël Mejía <[email protected]> AuthorDate: Wed Jun 20 09:26:48 2018 +0200 Merge pull request #5664: [BEAM-4570] Take pagination into account on PubsubJsonClient list methods .../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 38 ++++++++----- .../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 65 ++++++++++++++++++++-- 2 files changed, 86 insertions(+), 17 deletions(-) diff --cc sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java index efd9de0,88f7d4f..fb8485a --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java @@@ -18,10 -18,14 +18,15 @@@ package org.apache.beam.sdk.io.gcp.pubsub; +import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertEquals; + import static org.mockito.Mockito.when; import com.google.api.services.pubsub.Pubsub; + import com.google.api.services.pubsub.Pubsub.Projects.Subscriptions; + import com.google.api.services.pubsub.Pubsub.Projects.Topics; + import com.google.api.services.pubsub.model.ListSubscriptionsResponse; + import com.google.api.services.pubsub.model.ListTopicsResponse; import com.google.api.services.pubsub.model.PublishRequest; import com.google.api.services.pubsub.model.PublishResponse; import com.google.api.services.pubsub.model.PubsubMessage;
