---

j256 · pongad · commit 3f0328f86f91 · 2018-04-03T09:40:56.000-07:00
yaml --- r: 9279 b: refs/heads/spanner-gapic-migration c: 1e79087 h: refs/heads/master i: 9277: f8e5642 9275: 7d4ee76 9271: cf52609 9263: f645557 9247: a230a9b 9215: 241f8f3
diff --git a/[refs] b/[refs]
@@ -81,7 +81,7 @@ refs/tags/v0.35.0: c28951c5f4cc97a1be07900d19df6984115a4bd6
 refs/tags/v0.36.0: 6b75c61f73e6827b3ca379bd54f88f750290162f
 refs/tags/v0.37.0: db2e142f92601709fdd48db159776f905742e30f
 refs/heads/mrschmidt-sizefix: 627a3bfa30bb6f4f76af47b228c38b208dd921e0
-refs/heads/spanner-gapic-migration: d0a2fc2247926ee1192006ab36df2ee87c1dde93
+refs/heads/spanner-gapic-migration: 1e79087946dec7bc1a620ef620638ef58ab27396
 refs/tags/v0.38.0: c235ee4df5e1248e1769dae3f86a0d7ab7fd8301
 refs/tags/v0.39.0: ab231c9d22475242a43d6d9554aa4a3f736dab01
 refs/tags/v0.40.0: a1d5b05206cce7734365f1b910396a2c9d6605ec
diff --git a/branches/spanner-gapic-migration/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java b/branches/spanner-gapic-migration/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
@@ -290,7 +290,12 @@ public void run() {
     }
   }
 
-  private void publishAllOutstanding() {
+  /**
+   * Publish any outstanding batches if non-empty.   This method sends buffered messages, but does
+   * not wait for the send operations to complete.  To wait for messages to send, call {@code get}
+   * on the futures returned from {@code publish}.
+   */
+  public void publishAllOutstanding() {
     messagesBatchLock.lock();
     OutstandingBatch batchToSend;
     try {

Original file line number	Diff line number	Diff line change
`@@ -290,7 +290,12 @@ public void run() {`
`290`	`290`	`}`
`291`	`291`	`}`
`292`	`292`
`293`		`- private void publishAllOutstanding() {`
	`293`	`+ /**`
	`294`	`+ * Publish any outstanding batches if non-empty. This method sends buffered messages, but does`
	`295`	`+ * not wait for the send operations to complete. To wait for messages to send, call {@code get}`
	`296`	`+ * on the futures returned from {@code publish}.`
	`297`	`+ */`
	`298`	`+ public void publishAllOutstanding() {`
`294`	`299`	`messagesBatchLock.lock();`
`295`	`300`	`OutstandingBatch batchToSend;`
`296`	`301`	`try {`