---

pongad · web-flow · commit f448906fde93 · 2017-10-10T11:16:29.000+11:00
yaml --- r: 8789 b: refs/heads/lesv-patch-1 c: 1dad07a h: refs/heads/master i: 8787: adb9ad6
diff --git a/[refs] b/[refs]
@@ -66,7 +66,7 @@ refs/tags/v0.22.0: 18b298fe4bfe8ec2f20b0e0bf7ffdcce5cc3c5fe
 refs/heads/vam-google-patch-1: d0c8fee3a4074d0bf7360ce8c4f7f7223d0ee7b9
 refs/heads/vam-google-patch-CODEOWNERS: 2ac1616e25229e51d08a984708ef1918f91a35ee
 refs/heads/danoscarmike-patch-1: 7342a9916bce4ed00002c7202e2a16c5d46afaea
-refs/heads/lesv-patch-1: 540734e6e9bce69f47854d2aabfbe61f1ac53631
+refs/heads/lesv-patch-1: 1dad07a793925662ee0935f43033e61669b9af01
 refs/heads/ml-update-branch: 079dd6610017f5c51b9d1938c12d6d55b61513cf
 refs/heads/vkedia-patch-2: 7d8241388a9769a5c069334761b06c7012c878e7
 refs/heads/vkedia-patch-3: 4d128043acaa7db9160faf439d2ca6104e8a88cb
diff --git a/branches/lesv-patch-1/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java b/branches/lesv-patch-1/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java
@@ -82,7 +82,10 @@ public void failed(Subscriber.State from, Throwable failure) {
     subscriber.startAsync();
 
     // Wait for a stop signal.
+    // In a server, this might be a signal to stop serving.
+    // In this example, the signal is just a dummy Future.
     done.get();
+
     subscriber.stopAsync().awaitTerminated();
   }
 
diff --git a/branches/lesv-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java b/branches/lesv-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java
@@ -222,7 +222,10 @@ public FlowControlSettings getFlowControlSettings() {
    * subscriber.startAsync();
    *
    * // Wait for a stop signal.
+   * // In a server, this might be a signal to stop serving.
+   * // In this example, the signal is just a dummy Future.
    * done.get();
+   *
    * subscriber.stopAsync().awaitTerminated();
    * }</pre>
    */

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,10 @@ public void failed(Subscriber.State from, Throwable failure) {`
`82`	`82`	`subscriber.startAsync();`
`83`	`83`
`84`	`84`	`// Wait for a stop signal.`
	`85`	`+ // In a server, this might be a signal to stop serving.`
	`86`	`+ // In this example, the signal is just a dummy Future.`
`85`	`87`	`done.get();`
	`88`	`+`
`86`	`89`	`subscriber.stopAsync().awaitTerminated();`
`87`	`90`	`}`
`88`	`91`