---

sduskis · web-flow · commit a6745bb64d47 · 2019-04-30T15:06:30.000-04:00
yaml --- r: 35159 b: refs/heads/autosynth-websecurityscanner c: d2f0bc6 h: refs/heads/master i: 35157: 26e391e 35155: 6b1fe18 35151: 5d52c44
diff --git a/[refs] b/[refs]
@@ -142,7 +142,7 @@ refs/heads/autosynth-speech: c563dcd420cce0a37c39b1b9c24be1b9ba604dc7
 refs/heads/autosynth-tasks: 25d1eafe8cb66b00e3dad765dac74a5b45b83e63
 refs/heads/autosynth-texttospeech: 7a3ad430dddaed7a76f2026064502680c9339915
 refs/heads/autosynth-trace: 31564421a4b29f8257a6daea7f9a19838ac6459f
-refs/heads/autosynth-websecurityscanner: ff068a98c01b31c9cd416ff92e71c96ababcd204
+refs/heads/autosynth-websecurityscanner: d2f0bc64a53049040fe9c9d338b12fab3dd1ad6a
 refs/heads/bigquerystorage: 06db74d123d7f8a3ef48755c2fcabed09faf8e64
 refs/heads/elharo-patch-1: ce159ef828d3c545991ff78e7b6e0d912a9453e9
 refs/heads/snyk-fix-r0punm: 1f0e6519ffd9f6cc09bcce1ccdf3fb61b6f4f9b5
diff --git a/branches/autosynth-websecurityscanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java b/branches/autosynth-websecurityscanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
@@ -272,13 +272,13 @@ public void publishAllOutstanding() {
   }
 
   private ApiFuture<PublishResponse> publishCall(OutstandingBatch outstandingBatch) {
-    PublishRequest.Builder publishRequest = PublishRequest.newBuilder();
-    publishRequest.setTopic(topicName);
-    for (OutstandingPublish outstandingPublish : outstandingBatch.outstandingPublishes) {
-      publishRequest.addMessages(outstandingPublish.message);
-    }
-
-    return publisherStub.publishCallable().futureCall(publishRequest.build());
+    return publisherStub
+        .publishCallable()
+        .futureCall(
+            PublishRequest.newBuilder()
+                .setTopic(topicName)
+                .addAllMessages(outstandingBatch.getMessages())
+                .build());
   }
 
   private void publishOutstandingBatch(final OutstandingBatch outstandingBatch) {
@@ -342,6 +342,14 @@ private static final class OutstandingBatch {
     int size() {
       return outstandingPublishes.size();
     }
+
+    private List<PubsubMessage> getMessages() {
+      List<PubsubMessage> results = new ArrayList<>(outstandingPublishes.size());
+      for (OutstandingPublish outstandingPublish : outstandingPublishes) {
+        results.add(outstandingPublish.message);
+      }
+      return results;
+    }
   }
 
   private static final class OutstandingPublish {
