Skip to content

Commit f8a7867

Browse files
pongadpongad
authored
remove ListenableFuture from surface (#1599)
1 parent c04d163 commit f8a7867

File tree

25 files changed

+222
-133
lines changed

25 files changed

+222
-133
lines changed

‎google-cloud-errorreporting/src/main/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorGroupServiceClient.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ private final ErrorGroup getGroup(GetGroupRequest request) {
214214
* GetGroupRequest request = GetGroupRequest.newBuilder()
215215
* .setGroupNameWithGroupName(groupName)
216216
* .build();
217-
* ListenableFuture<ErrorGroup> future = errorGroupServiceClient.getGroupCallable().futureCall(request);
217+
* RpcFuture<ErrorGroup> future = errorGroupServiceClient.getGroupCallable().futureCall(request);
218218
* // Do something
219219
* ErrorGroup response = future.get();
220220
* }
@@ -281,7 +281,7 @@ private final ErrorGroup updateGroup(UpdateGroupRequest request) {
281281
* UpdateGroupRequest request = UpdateGroupRequest.newBuilder()
282282
* .setGroup(group)
283283
* .build();
284-
* ListenableFuture<ErrorGroup> future = errorGroupServiceClient.updateGroupCallable().futureCall(request);
284+
* RpcFuture<ErrorGroup> future = errorGroupServiceClient.updateGroupCallable().futureCall(request);
285285
* // Do something
286286
* ErrorGroup response = future.get();
287287
* }

‎google-cloud-errorreporting/src/main/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorStatsServiceClient.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -251,7 +251,7 @@ public final ListGroupStatsPagedResponse listGroupStats(ListGroupStatsRequest re
251251
* .setProjectNameWithProjectName(projectName)
252252
* .setTimeRange(timeRange)
253253
* .build();
254-
* ListenableFuture<ListGroupStatsPagedResponse> future = errorStatsServiceClient.listGroupStatsPagedCallable().futureCall(request);
254+
* RpcFuture<ListGroupStatsPagedResponse> future = errorStatsServiceClient.listGroupStatsPagedCallable().futureCall(request);
255255
* // Do something
256256
* for (ErrorGroupStats element : future.get().iterateAllElements()) {
257257
* // doThingsWith(element);
@@ -370,7 +370,7 @@ public final ListEventsPagedResponse listEvents(ListEventsRequest request) {
370370
* .setProjectNameWithProjectName(projectName)
371371
* .setGroupId(groupId)
372372
* .build();
373-
* ListenableFuture<ListEventsPagedResponse> future = errorStatsServiceClient.listEventsPagedCallable().futureCall(request);
373+
* RpcFuture<ListEventsPagedResponse> future = errorStatsServiceClient.listEventsPagedCallable().futureCall(request);
374374
* // Do something
375375
* for (ErrorEvent element : future.get().iterateAllElements()) {
376376
* // doThingsWith(element);
@@ -475,7 +475,7 @@ private final DeleteEventsResponse deleteEvents(DeleteEventsRequest request) {
475475
* DeleteEventsRequest request = DeleteEventsRequest.newBuilder()
476476
* .setProjectNameWithProjectName(projectName)
477477
* .build();
478-
* ListenableFuture<DeleteEventsResponse> future = errorStatsServiceClient.deleteEventsCallable().futureCall(request);
478+
* RpcFuture<DeleteEventsResponse> future = errorStatsServiceClient.deleteEventsCallable().futureCall(request);
479479
* // Do something
480480
* DeleteEventsResponse response = future.get();
481481
* }

‎google-cloud-errorreporting/src/main/java/com/google/cloud/errorreporting/spi/v1beta1/ReportErrorsServiceClient.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,7 @@ public final ReportErrorEventResponse reportErrorEvent(ReportErrorEventRequest r
241241
* .setProjectNameWithProjectName(projectName)
242242
* .setEvent(event)
243243
* .build();
244-
* ListenableFuture<ReportErrorEventResponse> future = reportErrorsServiceClient.reportErrorEventCallable().futureCall(request);
244+
* RpcFuture<ReportErrorEventResponse> future = reportErrorsServiceClient.reportErrorEventCallable().futureCall(request);
245245
* // Do something
246246
* ReportErrorEventResponse response = future.get();
247247
* }

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateSubscriptionAndPullMessages.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,11 +16,12 @@
1616

1717
package com.google.cloud.examples.pubsub.snippets;
1818

19+
import com.google.cloud.pubsub.spi.v1.AckReply;
20+
import com.google.cloud.pubsub.spi.v1.AckReplyConsumer;
1921
import com.google.cloud.pubsub.spi.v1.MessageReceiver;
2022
import com.google.cloud.pubsub.spi.v1.Subscriber;
2123
import com.google.cloud.pubsub.spi.v1.SubscriberClient;
2224
import com.google.common.util.concurrent.MoreExecutors;
23-
import com.google.common.util.concurrent.SettableFuture;
2425
import com.google.pubsub.v1.PubsubMessage;
2526
import com.google.pubsub.v1.PushConfig;
2627
import com.google.pubsub.v1.SubscriptionName;
@@ -43,10 +44,9 @@ public static void main(String... args) throws Exception {
4344
MessageReceiver receiver =
4445
new MessageReceiver() {
4546
@Override
46-
public void receiveMessage(
47-
PubsubMessage message, SettableFuture<MessageReceiver.AckReply> response) {
47+
public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
4848
System.out.println("got message: " + message.getData().toStringUtf8());
49-
response.set(MessageReceiver.AckReply.ACK);
49+
consumer.accept(AckReply.ACK, null);
5050
}
5151
};
5252
Subscriber subscriber = null;

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateTopicAndPublishMessages.java‎

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,10 +16,9 @@
1616

1717
package com.google.cloud.examples.pubsub.snippets;
1818

19+
import com.google.api.gax.core.RpcFuture;
1920
import com.google.cloud.pubsub.spi.v1.Publisher;
2021
import com.google.cloud.pubsub.spi.v1.PublisherClient;
21-
import com.google.common.util.concurrent.Futures;
22-
import com.google.common.util.concurrent.ListenableFuture;
2322
import com.google.protobuf.ByteString;
2423
import com.google.pubsub.v1.PubsubMessage;
2524
import com.google.pubsub.v1.TopicName;
@@ -42,15 +41,15 @@ public static void main(String... args) throws Exception {
4241
try {
4342
publisher = Publisher.newBuilder(topic).build();
4443
List<String> messages = Arrays.asList("first message", "second message");
45-
List<ListenableFuture<String>> messageIds = new ArrayList<>();
44+
List<RpcFuture<String>> messageIds = new ArrayList<>();
4645
for (String message : messages) {
4746
ByteString data = ByteString.copyFromUtf8(message);
4847
PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();
49-
ListenableFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
48+
RpcFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
5049
messageIds.add(messageIdFuture);
5150
}
52-
for (String messageId : Futures.allAsList(messageIds).get()) {
53-
System.out.println("published with message ID: " + messageId);
51+
for (RpcFuture<String> messageId : messageIds) {
52+
System.out.println("published with message ID: " + messageId.get());
5453
}
5554
} finally {
5655
if (publisher != null) {

‎google-cloud-language/src/main/java/com/google/cloud/language/spi/v1/LanguageServiceClient.java‎

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import com.google.cloud.language.v1.AnalyzeSyntaxRequest;
2525
import com.google.cloud.language.v1.AnalyzeSyntaxResponse;
2626
import com.google.cloud.language.v1.AnnotateTextRequest;
27-
import com.google.cloud.language.v1.AnnotateTextRequest.Features;
2827
import com.google.cloud.language.v1.AnnotateTextResponse;
2928
import com.google.cloud.language.v1.Document;
3029
import com.google.cloud.language.v1.EncodingType;
@@ -225,7 +224,7 @@ private final AnalyzeSentimentResponse analyzeSentiment(AnalyzeSentimentRequest
225224
* AnalyzeSentimentRequest request = AnalyzeSentimentRequest.newBuilder()
226225
* .setDocument(document)
227226
* .build();
228-
* ListenableFuture&lt;AnalyzeSentimentResponse&gt; future = languageServiceClient.analyzeSentimentCallable().futureCall(request);
227+
* RpcFuture&lt;AnalyzeSentimentResponse&gt; future = languageServiceClient.analyzeSentimentCallable().futureCall(request);
229228
* // Do something
230229
* AnalyzeSentimentResponse response = future.get();
231230
* }
@@ -307,7 +306,7 @@ public final AnalyzeEntitiesResponse analyzeEntities(AnalyzeEntitiesRequest requ
307306
* .setDocument(document)
308307
* .setEncodingType(encodingType)
309308
* .build();
310-
* ListenableFuture&lt;AnalyzeEntitiesResponse&gt; future = languageServiceClient.analyzeEntitiesCallable().futureCall(request);
309+
* RpcFuture&lt;AnalyzeEntitiesResponse&gt; future = languageServiceClient.analyzeEntitiesCallable().futureCall(request);
311310
* // Do something
312311
* AnalyzeEntitiesResponse response = future.get();
313312
* }
@@ -388,7 +387,7 @@ public final AnalyzeSyntaxResponse analyzeSyntax(AnalyzeSyntaxRequest request) {
388387
* .setDocument(document)
389388
* .setEncodingType(encodingType)
390389
* .build();
391-
* ListenableFuture&lt;AnalyzeSyntaxResponse&gt; future = languageServiceClient.analyzeSyntaxCallable().futureCall(request);
390+
* RpcFuture&lt;AnalyzeSyntaxResponse&gt; future = languageServiceClient.analyzeSyntaxCallable().futureCall(request);
392391
* // Do something
393392
* AnalyzeSyntaxResponse response = future.get();
394393
* }
@@ -476,7 +475,7 @@ public final AnnotateTextResponse annotateText(AnnotateTextRequest request) {
476475
* .setFeatures(features)
477476
* .setEncodingType(encodingType)
478477
* .build();
479-
* ListenableFuture&lt;AnnotateTextResponse&gt; future = languageServiceClient.annotateTextCallable().futureCall(request);
478+
* RpcFuture&lt;AnnotateTextResponse&gt; future = languageServiceClient.annotateTextCallable().futureCall(request);
480479
* // Do something
481480
* AnnotateTextResponse response = future.get();
482481
* }

‎google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/ConfigServiceV2Client.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ public final ListSinksPagedResponse listSinks(ListSinksRequest request) {
231231
* ListSinksRequest request = ListSinksRequest.newBuilder()
232232
* .setParentWithParentNameOneof(parent)
233233
* .build();
234-
* ListenableFuture&lt;ListSinksPagedResponse&gt; future = configServiceV2Client.listSinksPagedCallable().futureCall(request);
234+
* RpcFuture&lt;ListSinksPagedResponse&gt; future = configServiceV2Client.listSinksPagedCallable().futureCall(request);
235235
* // Do something
236236
* for (LogSink element : future.get().iterateAllElements()) {
237237
* // doThingsWith(element);
@@ -335,7 +335,7 @@ private final LogSink getSink(GetSinkRequest request) {
335335
* GetSinkRequest request = GetSinkRequest.newBuilder()
336336
* .setSinkNameWithSinkNameOneof(sinkName)
337337
* .build();
338-
* ListenableFuture&lt;LogSink&gt; future = configServiceV2Client.getSinkCallable().futureCall(request);
338+
* RpcFuture&lt;LogSink&gt; future = configServiceV2Client.getSinkCallable().futureCall(request);
339339
* // Do something
340340
* LogSink response = future.get();
341341
* }
@@ -421,7 +421,7 @@ public final LogSink createSink(CreateSinkRequest request) {
421421
* .setParentWithParentNameOneof(parent)
422422
* .setSink(sink)
423423
* .build();
424-
* ListenableFuture&lt;LogSink&gt; future = configServiceV2Client.createSinkCallable().futureCall(request);
424+
* RpcFuture&lt;LogSink&gt; future = configServiceV2Client.createSinkCallable().futureCall(request);
425425
* // Do something
426426
* LogSink response = future.get();
427427
* }
@@ -515,7 +515,7 @@ public final LogSink updateSink(UpdateSinkRequest request) {
515515
* .setSinkNameWithSinkNameOneof(sinkName)
516516
* .setSink(sink)
517517
* .build();
518-
* ListenableFuture&lt;LogSink&gt; future = configServiceV2Client.updateSinkCallable().futureCall(request);
518+
* RpcFuture&lt;LogSink&gt; future = configServiceV2Client.updateSinkCallable().futureCall(request);
519519
* // Do something
520520
* LogSink response = future.get();
521521
* }
@@ -591,7 +591,7 @@ private final void deleteSink(DeleteSinkRequest request) {
591591
* DeleteSinkRequest request = DeleteSinkRequest.newBuilder()
592592
* .setSinkNameWithSinkNameOneof(sinkName)
593593
* .build();
594-
* ListenableFuture&lt;Void&gt; future = configServiceV2Client.deleteSinkCallable().futureCall(request);
594+
* RpcFuture&lt;Void&gt; future = configServiceV2Client.deleteSinkCallable().futureCall(request);
595595
* // Do something
596596
* future.get();
597597
* }

‎google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/LoggingServiceV2Client.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@ private final void deleteLog(DeleteLogRequest request) {
256256
* DeleteLogRequest request = DeleteLogRequest.newBuilder()
257257
* .setLogNameWithLogNameOneof(logName)
258258
* .build();
259-
* ListenableFuture&lt;Void&gt; future = loggingServiceV2Client.deleteLogCallable().futureCall(request);
259+
* RpcFuture&lt;Void&gt; future = loggingServiceV2Client.deleteLogCallable().futureCall(request);
260260
* // Do something
261261
* future.get();
262262
* }
@@ -356,7 +356,7 @@ public final WriteLogEntriesResponse writeLogEntries(WriteLogEntriesRequest requ
356356
* WriteLogEntriesRequest request = WriteLogEntriesRequest.newBuilder()
357357
* .addAllEntries(entries)
358358
* .build();
359-
* ListenableFuture&lt;WriteLogEntriesResponse&gt; future = loggingServiceV2Client.writeLogEntriesCallable().futureCall(request);
359+
* RpcFuture&lt;WriteLogEntriesResponse&gt; future = loggingServiceV2Client.writeLogEntriesCallable().futureCall(request);
360360
* // Do something
361361
* WriteLogEntriesResponse response = future.get();
362362
* }
@@ -452,7 +452,7 @@ public final ListLogEntriesPagedResponse listLogEntries(ListLogEntriesRequest re
452452
* ListLogEntriesRequest request = ListLogEntriesRequest.newBuilder()
453453
* .addAllResourceNames(resourceNames)
454454
* .build();
455-
* ListenableFuture&lt;ListLogEntriesPagedResponse&gt; future = loggingServiceV2Client.listLogEntriesPagedCallable().futureCall(request);
455+
* RpcFuture&lt;ListLogEntriesPagedResponse&gt; future = loggingServiceV2Client.listLogEntriesPagedCallable().futureCall(request);
456456
* // Do something
457457
* for (LogEntry element : future.get().iterateAllElements()) {
458458
* // doThingsWith(element);
@@ -530,7 +530,7 @@ public final ListMonitoredResourceDescriptorsPagedResponse listMonitoredResource
530530
* <pre><code>
531531
* try (LoggingServiceV2Client loggingServiceV2Client = LoggingServiceV2Client.create()) {
532532
* ListMonitoredResourceDescriptorsRequest request = ListMonitoredResourceDescriptorsRequest.newBuilder().build();
533-
* ListenableFuture&lt;ListMonitoredResourceDescriptorsPagedResponse&gt; future = loggingServiceV2Client.listMonitoredResourceDescriptorsPagedCallable().futureCall(request);
533+
* RpcFuture&lt;ListMonitoredResourceDescriptorsPagedResponse&gt; future = loggingServiceV2Client.listMonitoredResourceDescriptorsPagedCallable().futureCall(request);
534534
* // Do something
535535
* for (MonitoredResourceDescriptor element : future.get().iterateAllElements()) {
536536
* // doThingsWith(element);
@@ -636,7 +636,7 @@ public final ListLogsPagedResponse listLogs(ListLogsRequest request) {
636636
* ListLogsRequest request = ListLogsRequest.newBuilder()
637637
* .setParentWithParentNameOneof(parent)
638638
* .build();
639-
* ListenableFuture&lt;ListLogsPagedResponse&gt; future = loggingServiceV2Client.listLogsPagedCallable().futureCall(request);
639+
* RpcFuture&lt;ListLogsPagedResponse&gt; future = loggingServiceV2Client.listLogsPagedCallable().futureCall(request);
640640
* // Do something
641641
* for (String element : future.get().iterateAllElements()) {
642642
* // doThingsWith(element);

‎google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/MetricsServiceV2Client.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,7 @@ public final ListLogMetricsPagedResponse listLogMetrics(ListLogMetricsRequest re
233233
* ListLogMetricsRequest request = ListLogMetricsRequest.newBuilder()
234234
* .setParentWithParentNameOneof(parent)
235235
* .build();
236-
* ListenableFuture&lt;ListLogMetricsPagedResponse&gt; future = metricsServiceV2Client.listLogMetricsPagedCallable().futureCall(request);
236+
* RpcFuture&lt;ListLogMetricsPagedResponse&gt; future = metricsServiceV2Client.listLogMetricsPagedCallable().futureCall(request);
237237
* // Do something
238238
* for (LogMetric element : future.get().iterateAllElements()) {
239239
* // doThingsWith(element);
@@ -337,7 +337,7 @@ private final LogMetric getLogMetric(GetLogMetricRequest request) {
337337
* GetLogMetricRequest request = GetLogMetricRequest.newBuilder()
338338
* .setMetricNameWithMetricNameOneof(metricName)
339339
* .build();
340-
* ListenableFuture&lt;LogMetric&gt; future = metricsServiceV2Client.getLogMetricCallable().futureCall(request);
340+
* RpcFuture&lt;LogMetric&gt; future = metricsServiceV2Client.getLogMetricCallable().futureCall(request);
341341
* // Do something
342342
* LogMetric response = future.get();
343343
* }
@@ -416,7 +416,7 @@ public final LogMetric createLogMetric(CreateLogMetricRequest request) {
416416
* .setParentWithParentNameOneof(parent)
417417
* .setMetric(metric)
418418
* .build();
419-
* ListenableFuture&lt;LogMetric&gt; future = metricsServiceV2Client.createLogMetricCallable().futureCall(request);
419+
* RpcFuture&lt;LogMetric&gt; future = metricsServiceV2Client.createLogMetricCallable().futureCall(request);
420420
* // Do something
421421
* LogMetric response = future.get();
422422
* }
@@ -497,7 +497,7 @@ public final LogMetric updateLogMetric(UpdateLogMetricRequest request) {
497497
* .setMetricNameWithMetricNameOneof(metricName)
498498
* .setMetric(metric)
499499
* .build();
500-
* ListenableFuture&lt;LogMetric&gt; future = metricsServiceV2Client.updateLogMetricCallable().futureCall(request);
500+
* RpcFuture&lt;LogMetric&gt; future = metricsServiceV2Client.updateLogMetricCallable().futureCall(request);
501501
* // Do something
502502
* LogMetric response = future.get();
503503
* }
@@ -566,7 +566,7 @@ private final void deleteLogMetric(DeleteLogMetricRequest request) {
566566
* DeleteLogMetricRequest request = DeleteLogMetricRequest.newBuilder()
567567
* .setMetricNameWithMetricNameOneof(metricName)
568568
* .build();
569-
* ListenableFuture&lt;Void&gt; future = metricsServiceV2Client.deleteLogMetricCallable().futureCall(request);
569+
* RpcFuture&lt;Void&gt; future = metricsServiceV2Client.deleteLogMetricCallable().futureCall(request);
570570
* // Do something
571571
* future.get();
572572
* }

‎google-cloud-monitoring/src/main/java/com/google/cloud/monitoring/spi/v3/GroupServiceClient.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,7 @@ public final ListGroupsPagedResponse listGroups(ListGroupsRequest request) {
226226
* ListGroupsRequest request = ListGroupsRequest.newBuilder()
227227
* .setNameWithProjectName(name)
228228
* .build();
229-
* ListenableFuture&lt;ListGroupsPagedResponse&gt; future = groupServiceClient.listGroupsPagedCallable().futureCall(request);
229+
* RpcFuture&lt;ListGroupsPagedResponse&gt; future = groupServiceClient.listGroupsPagedCallable().futureCall(request);
230230
* // Do something
231231
* for (Group element : future.get().iterateAllElements()) {
232232
* // doThingsWith(element);
@@ -327,7 +327,7 @@ private final Group getGroup(GetGroupRequest request) {
327327
* GetGroupRequest request = GetGroupRequest.newBuilder()
328328
* .setNameWithGroupName(name)
329329
* .build();
330-
* ListenableFuture&lt;Group&gt; future = groupServiceClient.getGroupCallable().futureCall(request);
330+
* RpcFuture&lt;Group&gt; future = groupServiceClient.getGroupCallable().futureCall(request);
331331
* // Do something
332332
* Group response = future.get();
333333
* }
@@ -403,7 +403,7 @@ public final Group createGroup(CreateGroupRequest request) {
403403
* .setNameWithProjectName(name)
404404
* .setGroup(group)
405405
* .build();
406-
* ListenableFuture&lt;Group&gt; future = groupServiceClient.createGroupCallable().futureCall(request);
406+
* RpcFuture&lt;Group&gt; future = groupServiceClient.createGroupCallable().futureCall(request);
407407
* // Do something
408408
* Group response = future.get();
409409
* }
@@ -471,7 +471,7 @@ public final Group updateGroup(UpdateGroupRequest request) {
471471
* UpdateGroupRequest request = UpdateGroupRequest.newBuilder()
472472
* .setGroup(group)
473473
* .build();
474-
* ListenableFuture&lt;Group&gt; future = groupServiceClient.updateGroupCallable().futureCall(request);
474+
* RpcFuture&lt;Group&gt; future = groupServiceClient.updateGroupCallable().futureCall(request);
475475
* // Do something
476476
* Group response = future.get();
477477
* }
@@ -539,7 +539,7 @@ private final void deleteGroup(DeleteGroupRequest request) {
539539
* DeleteGroupRequest request = DeleteGroupRequest.newBuilder()
540540
* .setNameWithGroupName(name)
541541
* .build();
542-
* ListenableFuture&lt;Void&gt; future = groupServiceClient.deleteGroupCallable().futureCall(request);
542+
* RpcFuture&lt;Void&gt; future = groupServiceClient.deleteGroupCallable().futureCall(request);
543543
* // Do something
544544
* future.get();
545545
* }
@@ -611,7 +611,7 @@ public final ListGroupMembersPagedResponse listGroupMembers(ListGroupMembersRequ
611611
* ListGroupMembersRequest request = ListGroupMembersRequest.newBuilder()
612612
* .setNameWithGroupName(name)
613613
* .build();
614-
* ListenableFuture&lt;ListGroupMembersPagedResponse&gt; future = groupServiceClient.listGroupMembersPagedCallable().futureCall(request);
614+
* RpcFuture&lt;ListGroupMembersPagedResponse&gt; future = groupServiceClient.listGroupMembersPagedCallable().futureCall(request);
615615
* // Do something
616616
* for (MonitoredResource element : future.get().iterateAllElements()) {
617617
* // doThingsWith(element);

0 commit comments

Comments
 (0)