---

j256 · pongad · commit d454547e7d1a · 2018-04-03T09:40:56.000-07:00
yaml --- r: 9199 b: refs/heads/master c: 1e79087 h: refs/heads/master i: 9197: c7d07a0 9195: 0520495 9191: 0bd42c7 9183: 1cc614c
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: d0a2fc2247926ee1192006ab36df2ee87c1dde93
+refs/heads/master: 1e79087946dec7bc1a620ef620638ef58ab27396
 refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
 refs/heads/gh-pages: c44712253909b883eff39836632d6fa5763aa5af
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java b/trunk/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 {`