diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/TopicSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/TopicSnippets.java
new file mode 100644
index 000000000000..368481266a5f
--- /dev/null
+++ b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/TopicSnippets.java
@@ -0,0 +1,332 @@
+/*
+ * Copyright 2016 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ * EDITING INSTRUCTIONS
+ * This file is referenced in Topic's javadoc. Any change to this file should be reflected in
+ * Topic's javadoc.
+ */
+
+package com.google.cloud.examples.pubsub.snippets;
+
+import com.google.cloud.AsyncPage;
+import com.google.cloud.Identity;
+import com.google.cloud.Page;
+import com.google.cloud.Policy;
+import com.google.cloud.Role;
+import com.google.cloud.pubsub.Message;
+import com.google.cloud.pubsub.PubSub.ListOption;
+import com.google.cloud.pubsub.SubscriptionId;
+import com.google.cloud.pubsub.Topic;
+
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+/**
+ * This class contains a number of snippets for the {@link Topic} class.
+ */
+public class TopicSnippets {
+
+  private final Topic topic;
+
+  public TopicSnippets(Topic topic) {
+    this.topic = topic;
+  }
+
+  /**
+   * Example of getting the topic's latest information.
+   */
+  // [TARGET reload()]
+  public Topic reload() {
+    // [START reload]
+    Topic latestTopic = topic.reload();
+    if (latestTopic == null) {
+      // the topic was not found
+    }
+    // [END reload]
+    return latestTopic;
+  }
+
+  /**
+   * Example of asynchronously getting the topic's latest information.
+   */
+  // [TARGET reloadAsync()]
+  public Topic reloadAsync() throws ExecutionException, InterruptedException {
+    // [START reloadAsync]
+    Future<Topic> future = topic.reloadAsync();
+    // ...
+    Topic latestTopic = future.get();
+    if (latestTopic == null) {
+      // the topic was not found
+    }
+    // [END reloadAsync]
+    return latestTopic;
+  }
+
+  /**
+   * Example of deleting the topic.
+   */
+  // [TARGET delete()]
+  public boolean delete() {
+    // [START delete]
+    boolean deleted = topic.delete();
+    if (deleted) {
+      // the topic was deleted
+    } else {
+      // the topic was not found
+    }
+    // [END delete]
+    return deleted;
+  }
+
+  /**
+   * Example of asynchronously deleting the topic.
+   */
+  // [TARGET deleteAsync()]
+  public boolean deleteAsync() throws ExecutionException, InterruptedException {
+    // [START deleteAsync]
+    Future<Boolean> future = topic.deleteAsync();
+    // ...
+    boolean deleted = future.get();
+    if (deleted) {
+      // the topic was deleted
+    } else {
+      // the topic was not found
+    }
+    // [END deleteAsync]
+    return deleted;
+  }
+
+  /**
+   * Example of publishing one message to the topic.
+   */
+  // [TARGET publish(Message)]
+  public String publishOneMessage() {
+    // [START publishOneMessage]
+    Message message = Message.of("payload");
+    String messageId = topic.publish(message);
+    // [END publishOneMessage]
+    return messageId;
+  }
+
+  /**
+   * Example of asynchronously publishing one message to the topic.
+   */
+  // [TARGET publishAsync(Message)]
+  public String publishOneMessageAsync()
+      throws ExecutionException, InterruptedException {
+    // [START publishOneMessageAsync]
+    Message message = Message.of("payload");
+    Future<String> future = topic.publishAsync(message);
+    // ...
+    String messageId = future.get();
+    // [END publishOneMessageAsync]
+    return messageId;
+  }
+
+
+  /**
+   * Example of publishing a list of messages to the topic.
+   */
+  // [TARGET publish(Iterable)]
+  public List<String> publishMessageList() {
+    // [START publishMessageList]
+    List<Message> messages = new LinkedList<>();
+    messages.add(Message.of("payload1"));
+    messages.add(Message.of("payload2"));
+    List<String> messageIds = topic.publish(messages);
+    // [END publishMessageList]
+    return messageIds;
+  }
+
+  /**
+   * Example of asynchronously publishing a list of messages to the topic.
+   */
+  // [TARGET publishAsync(Iterable)]
+  public List<String> publishMessageListAsync()
+      throws ExecutionException, InterruptedException {
+    // [START publishMessageListAsync]
+    List<Message> messages = new LinkedList<>();
+    messages.add(Message.of("payload1"));
+    messages.add(Message.of("payload2"));
+    Future<List<String>> future = topic.publishAsync(messages);
+    // ...
+    List<String> messageIds = future.get();
+    // [END publishMessageListAsync]
+    return messageIds;
+  }
+
+  /**
+   * Example of publishing some messages to the topic.
+   */
+  // [TARGET publish(Message, Message...)]
+  public List<String> publishMessages() {
+    // [START publishMessages]
+    Message message1 = Message.of("payload1");
+    Message message2 = Message.of("payload2");
+    List<String> messageIds = topic.publish(message1, message2);
+    // [END publishMessages]
+    return messageIds;
+  }
+
+  /**
+   * Example of asynchronously publishing some messages to the topic.
+   */
+  // [TARGET publishAsync(Message, Message...)]
+  public List<String> publishMessagesAsync()
+      throws ExecutionException, InterruptedException {
+    // [START publishMessagesAsync]
+    Message message1 = Message.of("payload1");
+    Message message2 = Message.of("payload2");
+    Future<List<String>> future = topic.publishAsync(message1, message2);
+    // ...
+    List<String> messageIds = future.get();
+    // [END publishMessagesAsync]
+    return messageIds;
+  }
+
+  /**
+   * Example of listing subscriptions for the topic, specifying the page size.
+   */
+  // [TARGET listSubscriptions(ListOption...)]
+  public Page<SubscriptionId> listSubscriptionsForTopic() {
+    // [START listSubscriptionsForTopic]
+    Page<SubscriptionId> subscriptions = topic.listSubscriptions(ListOption.pageSize(100));
+    Iterator<SubscriptionId> subscriptionIterator = subscriptions.iterateAll();
+    while (subscriptionIterator.hasNext()) {
+      SubscriptionId subscription = subscriptionIterator.next();
+      // do something with the subscription identity
+    }
+    // [END listSubscriptionsForTopic]
+    return subscriptions;
+  }
+
+  /**
+   * Example of asynchronously listing subscriptions for the topic, specifying the page size.
+   */
+  // [TARGET listSubscriptionsAsync(ListOption...)]
+  public Page<SubscriptionId> listSubscriptionsForTopicAsync()
+      throws ExecutionException, InterruptedException {
+    // [START listSubscriptionsForTopicAsync]
+    Future<AsyncPage<SubscriptionId>> future =
+        topic.listSubscriptionsAsync(ListOption.pageSize(100));
+    // ...
+    AsyncPage<SubscriptionId> subscriptions = future.get();
+    Iterator<SubscriptionId> subscriptionIterator = subscriptions.iterateAll();
+    while (subscriptionIterator.hasNext()) {
+      SubscriptionId subscription = subscriptionIterator.next();
+      // do something with the subscription identity
+    }
+    // [END listSubscriptionsForTopicAsync]
+    return subscriptions;
+  }
+
+  /**
+   * Example of getting the topic's policy.
+   */
+  // [TARGET getPolicy()]
+  public Policy getPolicy() {
+    // [START getPolicy]
+    Policy policy = topic.getPolicy();
+    if (policy == null) {
+      // topic was not found
+    }
+    // [END getPolicy]
+    return policy;
+  }
+
+  /**
+   * Example of asynchronously getting the topic's policy.
+   */
+  // [TARGET getPolicyAsync()]
+  public Policy getPolicyAsync() throws ExecutionException, InterruptedException {
+    // [START getPolicyAsync]
+    Future<Policy> future = topic.getPolicyAsync();
+    // ...
+    Policy policy = future.get();
+    if (policy == null) {
+      // topic was not found
+    }
+    // [END getPolicyAsync]
+    return policy;
+  }
+
+  /**
+   * Example of replacing the topic's policy.
+   */
+  // [TARGET replacePolicy(Policy)]
+  public Policy replacePolicy() {
+    // [START replacePolicy]
+    Policy policy = topic.getPolicy();
+    Policy updatedPolicy = policy.toBuilder()
+        .addIdentity(Role.viewer(), Identity.allAuthenticatedUsers())
+        .build();
+    updatedPolicy = topic.replacePolicy(updatedPolicy);
+    // [END replacePolicy]
+    return updatedPolicy;
+  }
+
+  /**
+   * Example of asynchronously replacing the topic's policy.
+   */
+  // [TARGET replacePolicyAsync(Policy)]
+  public Policy replacePolicyAsync()
+      throws ExecutionException, InterruptedException {
+    // [START replacePolicyAsync]
+    Policy policy = topic.getPolicy();
+    Policy updatedPolicy = policy.toBuilder()
+        .addIdentity(Role.viewer(), Identity.allAuthenticatedUsers())
+        .build();
+    Future<Policy> future = topic.replacePolicyAsync(updatedPolicy);
+    // ...
+    updatedPolicy = future.get();
+    // [END replacePolicyAsync]
+    return updatedPolicy;
+  }
+
+  /**
+   * Example of testing whether the caller has the provided permissions on the topic.
+   */
+  // [TARGET testPermissions(List)]
+  public List<Boolean> testPermissions() {
+    // [START testPermissions]
+    List<String> permissions = new LinkedList<>();
+    permissions.add("pubsub.topics.get");
+    List<Boolean> testedPermissions = topic.testPermissions(permissions);
+    // [END testPermissions]
+    return testedPermissions;
+  }
+
+  /**
+   * Example of asynchronously testing whether the caller has the provided permissions on the
+   * topic.
+   */
+  // [TARGET testPermissionsAsync(List)]
+  public List<Boolean> testPermissionsAsync()
+      throws ExecutionException, InterruptedException {
+    // [START testPermissionsAsync]
+    List<String> permissions = new LinkedList<>();
+    permissions.add("pubsub.topics.get");
+    Future<List<Boolean>> future = topic.testPermissionsAsync(permissions);
+    // ...
+    List<Boolean> testedPermissions = future.get();
+    // [END testPermissionsAsync]
+    return testedPermissions;
+  }
+}
diff --git a/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITTopicSnippets.java b/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITTopicSnippets.java
new file mode 100644
index 000000000000..4a091c45248c
--- /dev/null
+++ b/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITTopicSnippets.java
@@ -0,0 +1,118 @@
+/*
+ * Copyright 2016 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.examples.pubsub.snippets;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import com.google.cloud.Identity;
+import com.google.cloud.Page;
+import com.google.cloud.Policy;
+import com.google.cloud.Role;
+import com.google.cloud.pubsub.PubSub;
+import com.google.cloud.pubsub.PubSubOptions;
+import com.google.cloud.pubsub.SubscriptionId;
+import com.google.cloud.pubsub.SubscriptionInfo;
+import com.google.cloud.pubsub.Topic;
+import com.google.cloud.pubsub.TopicInfo;
+import com.google.common.collect.Iterators;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.util.UUID;
+import java.util.concurrent.ExecutionException;
+
+public class ITTopicSnippets {
+
+  private static final String TOPIC = "it-topic-snippets-topic-" + UUID.randomUUID().toString();
+  private static final String SUBSCRIPTION =
+      "it-topic-snippets-subscription-" + UUID.randomUUID().toString();
+
+  private static PubSub pubsub;
+  private static Topic topic;
+
+  @BeforeClass
+  public static void beforeClass() {
+    pubsub = PubSubOptions.defaultInstance().service();
+    topic = pubsub.create(TopicInfo.of(TOPIC));
+  }
+
+  @AfterClass
+  public static void afterClass() throws Exception {
+    if (pubsub != null) {
+      topic.delete();
+      pubsub.close();
+    }
+  }
+
+  @Test
+  public void testTopic() throws ExecutionException, InterruptedException {
+    TopicSnippets topicSnippets = new TopicSnippets(topic);
+    Topic updatedTopic = topicSnippets.reload();
+    assertEquals(topic, updatedTopic);
+    updatedTopic = topicSnippets.reloadAsync();
+    assertEquals(topic, updatedTopic);
+    assertNotNull(topicSnippets.publishOneMessage());
+    assertNotNull(topicSnippets.publishOneMessageAsync());
+    assertEquals(2, topicSnippets.publishMessageList().size());
+    assertEquals(2, topicSnippets.publishMessageListAsync().size());
+    assertEquals(2, topicSnippets.publishMessages().size());
+    assertEquals(2, topicSnippets.publishMessagesAsync().size());
+  }
+
+  @Test
+  public void testTopicSubscriptions() throws ExecutionException, InterruptedException {
+    TopicSnippets topicSnippets = new TopicSnippets(topic);
+    pubsub.create(SubscriptionInfo.of(TOPIC, SUBSCRIPTION));
+    try {
+      Page<SubscriptionId> subscriptions = topicSnippets.listSubscriptionsForTopic();
+      while (Iterators.size(subscriptions.values().iterator()) < 1) {
+        subscriptions = topicSnippets.listSubscriptionsForTopic();
+      }
+      assertEquals(SUBSCRIPTION, subscriptions.values().iterator().next().subscription());
+      subscriptions = topicSnippets.listSubscriptionsForTopicAsync();
+      while (Iterators.size(subscriptions.values().iterator()) < 1) {
+        subscriptions = topicSnippets.listSubscriptionsForTopic();
+      }
+      assertEquals(SUBSCRIPTION, subscriptions.values().iterator().next().subscription());
+    } finally {
+      pubsub.deleteSubscription(SUBSCRIPTION);
+    }
+  }
+
+  @Test
+  public void testPolicy() throws ExecutionException, InterruptedException {
+    TopicSnippets topicSnippets = new TopicSnippets(topic);
+    Policy policy = topicSnippets.getPolicy();
+    assertNotNull(policy);
+    assertEquals(policy, topicSnippets.getPolicyAsync());
+    policy = topicSnippets.replacePolicy();
+    assertTrue(policy.bindings().get(Role.viewer()).contains(Identity.allAuthenticatedUsers()));
+    policy = topic.replacePolicy(policy.toBuilder()
+        .removeIdentity(Role.viewer(), Identity.allAuthenticatedUsers())
+        .build());
+    assertFalse(policy.bindings().containsKey(Role.viewer()));
+    policy = topicSnippets.replacePolicyAsync();
+    assertTrue(policy.bindings().get(Role.viewer()).contains(Identity.allAuthenticatedUsers()));
+    assertTrue(topicSnippets.delete());
+    assertFalse(topicSnippets.deleteAsync());
+  }
+}
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/Topic.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/Topic.java
index e0c3cbf30f0f..d4b9e9069636 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/Topic.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/Topic.java
@@ -109,6 +109,16 @@ public PubSub pubSub() {
   /**
    * Deletes this topic.
    *
+   * <p>Example of deleting the topic.
+   * <pre> {@code
+   * boolean deleted = topic.delete();
+   * if (deleted) {
+   *   // the topic was deleted
+   * } else {
+   *   // the topic was not found
+   * }
+   * }</pre>
+   *
    * @return {@code true} if the topic was deleted, {@code false} if it was not found
    * @throws PubSubException upon failure
    */
@@ -121,6 +131,18 @@ public boolean delete() {
    * the result. {@link Future#get()} returns {@code true} if the topic was deleted, {@code false}
    * if it was not found.
    *
+   * <p>Example of asynchronously deleting the topic.
+   * <pre> {@code
+   * Future<Boolean> future = topic.deleteAsync();
+   * // ...
+   * boolean deleted = future.get();
+   * if (deleted) {
+   *   // the topic was deleted
+   * } else {
+   *   // the topic was not found
+   * }
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Future<Boolean> deleteAsync() {
@@ -130,6 +152,14 @@ public Future<Boolean> deleteAsync() {
   /**
    * Fetches current topic's latest information. Returns {@code null} if the topic does not exist.
    *
+   * <p>Example of getting the topic's latest information.
+   * <pre> {@code
+   * Topic latestTopic = topic.reload();
+   * if (latestTopic == null) {
+   *   // the topic was not found
+   * }
+   * }</pre>
+   *
    * @return a {@code Topic} object with latest information or {@code null} if not found
    * @throws PubSubException upon failure
    */
@@ -142,6 +172,16 @@ public Topic reload() {
    * {@code Future} object to consume the result. {@link Future#get()} returns a {@code Topic}
    * object with latest information or {@code null} if not found.
    *
+   * <p>Example of asynchronously getting the topic's latest information.
+   * <pre> {@code
+   * Future<Topic> future = topic.reloadAsync();
+   * // ...
+   * Topic latestTopic = future.get();
+   * if (latestTopic == null) {
+   *   // the topic was not found
+   * }
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Future<Topic> reloadAsync() {
@@ -152,6 +192,12 @@ public Future<Topic> reloadAsync() {
    * Publishes a message to this topic. This method returns a service-generated id for the published
    * message. Service-generated ids are guaranteed to be unique within the topic.
    *
+   * <p>Example of publishing one message to the topic.
+   * <pre> {@code
+   * Message message = Message.of("payload");
+   * String messageId = topic.publish(message);
+   * }</pre>
+   *
    * @param message the message to publish
    * @return a unique service-generated id for the message
    * @throws PubSubException upon failure, if the topic does not exist or if the message has empty
@@ -167,6 +213,14 @@ public String publish(Message message) {
    * id for the published message. Service-generated ids are guaranteed to be unique within the
    * topic.
    *
+   * <p>Example of asynchronously publishing one message to the topic.
+   * <pre> {@code
+   * Message message = Message.of("payload");
+   * Future<String> future = topic.publishAsync(message);
+   * // ...
+   * String messageId = future.get();
+   * }</pre>
+   *
    * @param message the message to publish
    * @return a {@code Future} for the unique service-generated id for the message
    */
@@ -179,6 +233,13 @@ public Future<String> publishAsync(Message message) {
    * ids for the published messages. Service-generated ids are guaranteed to be unique within the
    * topic.
    *
+   * <p>Example of publishing some messages to the topic.
+   * <pre> {@code
+   * Message message1 = Message.of("payload1");
+   * Message message2 = Message.of("payload2");
+   * List<String> messageIds = topic.publish(message1, message2);
+   * }</pre>
+   *
    * @param message the first message to publish
    * @param messages other messages to publish
    * @return a list of unique, service-generated, ids. Ids are in the same order as the messages.
@@ -195,6 +256,15 @@ public List<String> publish(Message message, Message... messages) {
    * service-generated ids for the published messages. Service-generated ids are guaranteed to be
    * unique within the topic.
    *
+   * <p>Example of asynchronously publishing some messages to the topic.
+   * <pre> {@code
+   * Message message1 = Message.of("payload1");
+   * Message message2 = Message.of("payload2");
+   * Future<List<String>> future = topic.publishAsync(message1, message2);
+   * // ...
+   * List<String> messageIds = future.get();
+   * }</pre>
+   *
    * @param message the first message to publish
    * @param messages other messages to publish
    * @return a {@code Future} for the unique, service-generated ids. Ids are in the same order as
@@ -209,6 +279,14 @@ public Future<List<String>> publishAsync(Message message, Message... messages) {
    * ids for the published messages. Service-generated ids are guaranteed to be unique within the
    * topic.
    *
+   * <p>Example of publishing a list of messages to the topic.
+   * <pre> {@code
+   * List<Message> messages = new LinkedList<>();
+   * messages.add(Message.of("payload1"));
+   * messages.add(Message.of("payload2"));
+   * List<String> messageIds = topic.publish(messages);
+   * }</pre>
+   *
    * @param messages the messages to publish
    * @return a list of unique, service-generated, ids. Ids are in the same order as the messages.
    * @throws PubSubException upon failure, if the topic does not exist or if one of the messages has
@@ -224,6 +302,16 @@ public List<String> publish(Iterable<Message> messages) {
    * service-generated ids for the published messages. Service-generated ids are guaranteed to be
    * unique within the topic.
    *
+   * <p>Example of asynchronously publishing a list of messages to the topic.
+   * <pre> {@code
+   * List<Message> messages = new LinkedList<>();
+   * messages.add(Message.of("payload1"));
+   * messages.add(Message.of("payload2"));
+   * Future<List<String>> future = topic.publishAsync(messages);
+   * // ...
+   * List<String> messageIds = future.get();
+   * }</pre>
+   *
    * @param messages the messages to publish
    * @return a {@code Future} for the unique, service-generated ids. Ids are in the same order as
    *     the messages.
@@ -237,6 +325,16 @@ public Future<List<String>> publishAsync(Iterable<Message> messages) {
    * object that can be used to consume paginated results. Use {@link ListOption} to specify the
    * page size or the page token from which to start listing subscriptions.
    *
+   * <p>Example of listing subscriptions for the topic, specifying the page size.
+   * <pre> {@code
+   * Page<SubscriptionId> subscriptions = topic.listSubscriptions(ListOption.pageSize(100));
+   * Iterator<SubscriptionId> subscriptionIterator = subscriptions.iterateAll();
+   * while (subscriptionIterator.hasNext()) {
+   *   SubscriptionId subscription = subscriptionIterator.next();
+   *   // do something with the subscription identity
+   * }
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Page<SubscriptionId> listSubscriptions(ListOption... options) {
@@ -249,6 +347,20 @@ public Page<SubscriptionId> listSubscriptions(ListOption... options) {
    * {@link AsyncPage} object that can be used to asynchronously handle paginated results. Use
    * {@link ListOption} to specify the page size or the page token from which to start listing
    * subscriptions.
+   *
+   * <p>Example of asynchronously listing subscriptions for the topic, specifying the page size.
+   * <pre> {@code
+   * Future<AsyncPage<SubscriptionId>> future =
+   *     topic.listSubscriptionsAsync(ListOption.pageSize(100));
+   * // ...
+   * AsyncPage<SubscriptionId> subscriptions = future.get();
+   * Iterator<SubscriptionId> subscriptionIterator = subscriptions.iterateAll();
+   * while (subscriptionIterator.hasNext()) {
+   *   SubscriptionId subscription = subscriptionIterator.next();
+   *   // do something with the subscription identity
+   * }
+   * }</pre>
+   *
    */
   public Future<AsyncPage<SubscriptionId>> listSubscriptionsAsync(ListOption... options) {
     return pubsub.listSubscriptionsAsync(name(), options);
@@ -258,6 +370,14 @@ public Future<AsyncPage<SubscriptionId>> listSubscriptionsAsync(ListOption... op
    * Returns the IAM access control policy for this topic. Returns {@code null} if the topic was not
    * found.
    *
+   * <p>Example of getting the topic's policy.
+   * <pre> {@code
+   * Policy policy = topic.getPolicy();
+   * if (policy == null) {
+   *   // topic was not found
+   * }
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Policy getPolicy() {
@@ -269,6 +389,16 @@ public Policy getPolicy() {
    * {@code Future} object to consume the result. {@link Future#get()} returns the requested policy
    * or {@code null} if the topic was not found.
    *
+   * <p>Example of asynchronously getting the topic's policy.
+   * <pre> {@code
+   * Future<Policy> future = topic.getPolicyAsync();
+   * // ...
+   * Policy policy = future.get();
+   * if (policy == null) {
+   *   // topic was not found
+   * }
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Future<Policy> getPolicyAsync() {
@@ -289,6 +419,15 @@ public Future<Policy> getPolicyAsync() {
    * {@code PubSubException} is thrown, denoting that the server aborted update. If an etag is not
    * provided, the policy is overwritten blindly.
    *
+   * <p>Example of replacing the topic's policy.
+   * <pre> {@code
+   * Policy policy = topic.getPolicy();
+   * Policy updatedPolicy = policy.toBuilder()
+   *     .addIdentity(Role.viewer(), Identity.allAuthenticatedUsers())
+   *     .build();
+   * updatedPolicy = topic.replacePolicy(updatedPolicy);
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Policy replacePolicy(Policy newPolicy) {
@@ -311,6 +450,17 @@ public Policy replacePolicy(Policy newPolicy) {
    * {@code PubSubException}, denoting that the server aborted update. If an etag is not provided,
    * the policy is overwritten blindly.
    *
+   * <p>Example of asynchronously replacing the topic's policy.
+   * <pre> {@code
+   * Policy policy = topic.getPolicy();
+   * Policy updatedPolicy = policy.toBuilder()
+   *     .addIdentity(Role.viewer(), Identity.allAuthenticatedUsers())
+   *     .build();
+   * Future<Policy> future = topic.replacePolicyAsync(updatedPolicy);
+   * // ...
+   * updatedPolicy = future.get();
+   * }</pre>
+   *
    * @throws PubSubException upon failure
    */
   public Future<Policy> replacePolicyAsync(Policy newPolicy) {
@@ -325,6 +475,13 @@ public Future<Policy> replacePolicyAsync(Policy newPolicy) {
    * such as a customized graphical user interface. For example, the Cloud Platform Console tests
    * IAM permissions internally to determine which UI should be available to the logged-in user.
    *
+   * <p>Example of testing whether the caller has the provided permissions on the topic.
+   * <pre> {@code
+   * List<String> permissions = new LinkedList<>();
+   * permissions.add("pubsub.topics.get");
+   * List<Boolean> testedPermissions = topic.testPermissions(permissions);
+   * }</pre>
+   *
    * @return A list of booleans representing whether the caller has the permissions specified (in
    *     the order of the given permissions)
    * @throws PubSubException upon failure
@@ -343,6 +500,16 @@ public List<Boolean> testPermissions(List<String> permissions) {
    * such as a customized graphical user interface. For example, the Cloud Platform Console tests
    * IAM permissions internally to determine which UI should be available to the logged-in user.
    *
+   * <p>Example of asynchronously testing whether the caller has the provided permissions on the
+   * topic.
+   * <pre> {@code
+   * List<String> permissions = new LinkedList<>();
+   * permissions.add("pubsub.topics.get");
+   * Future<List<Boolean>> future = topic.testPermissionsAsync(permissions);
+   * // ...
+   * List<Boolean> testedPermissions = future.get();
+   * }</pre>
+   *
    * @return A {@code Future} object to consume the result. {@link Future#get()} returns a list of
    *     booleans representing whether the caller has the permissions specified (in the order of the
    *     given permissions)