update snippet

pongad · pongad · commit 4f95f595684e · 2017-02-21T15:31:06.000+11:00
diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriberSnippets.java
@@ -45,8 +45,6 @@ public SubscriberSnippets(SubscriptionName subscription) {
    * Example of receiving a specific number of messages.
    */
   // [TARGET startAsync()]
-  // [VARIABLE "my_project_name"]
-  // [VARIABLE "my_subscription_name"]
   // [VARIABLE 3]
   public void startAsync(int receiveNum) throws Exception {
     // [START startAsync]
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java
@@ -182,60 +182,36 @@ public boolean isRunning() {
    *
    * <p>Example of receiving a specific number of messages.
    * <pre> {@code
-   * String projectName = "my_project_name";
-   * String subscriptionName = "my_subscription_name";
    * int receiveNum = 3;
-   * SubscriptionName subscription = SubscriptionName.create(projectName, subscriptionName);
-   * final Lock lock = new ReentrantLock();
-   * final Condition doneCondition = lock.newCondition();
    * final AtomicInteger pendingReceives = new AtomicInteger(receiveNum);
-   * final AtomicBoolean done = new AtomicBoolean();
-   *
+   * final SettableRpcFuture<Void> done = new SettableRpcFuture<>();
+   * 
    * MessageReceiver receiver = new MessageReceiver() {
    *   public void receiveMessage(final PubsubMessage message, final AckReplyConsumer consumer) {
    *     System.out.println("got message: " + message);
    *     consumer.accept(AckReply.ACK, null);
-   *     if (pendingReceives.decrementAndGet() != 0) {
-   *       return;
-   *     }
-   *     lock.lock();
-   *     try {
-   *       done.set(true);
-   *       doneCondition.signal();
-   *     } finally {
-   *       lock.unlock();
+   *     if (pendingReceives.decrementAndGet() == 0) {
+   *       done.set(null);
    *     }
    *   }
    * };
-   *
+   * 
    * Subscriber subscriber = Subscriber.newBuilder(subscription, receiver).build();
    * subscriber.addListener(new Subscriber.SubscriberListener() {
    *   public void failed(Subscriber.State from, Throwable failure) {
-   *     System.err.println(failure);
-   *     lock.lock();
-   *     try {
-   *       done.set(true);
-   *       doneCondition.signal();
-   *     } finally {
-   *       lock.unlock();
-   *     }
+   *     done.setException(failure);
    *   }
    * }, new Executor() {
    *   public void execute(Runnable command) {
    *     command.run();
    *   }
    * });
    * subscriber.startAsync();
-   * lock.lock();
-   * try {
-   *   while (!done.get()) {
-   *     doneCondition.await();
-   *   }
-   * } finally {
-   *   lock.unlock();
-   * }
+   * 
+   * done.get(10, TimeUnit.MINUTES);
    * subscriber.stopAsync().awaitTerminated();
    * }</pre>
+   *
    */
   public Subscriber startAsync() {
     impl.startAsync();
