MessagingClient.golden

package com.google.showcase.v1beta1;

import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.api.gax.paging.AbstractFixedSizeCollection;
import com.google.api.gax.paging.AbstractPage;
import com.google.api.gax.paging.AbstractPagedListResponse;
import com.google.api.gax.rpc.BidiStreamingCallable;
import com.google.api.gax.rpc.ClientStreamingCallable;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.PageContext;
import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.longrunning.Operation;
import com.google.longrunning.OperationsClient;
import com.google.protobuf.ByteString;
import com.google.protobuf.Empty;
import com.google.showcase.v1beta1.stub.MessagingStub;
import com.google.showcase.v1beta1.stub.MessagingStubSettings;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

// AUTO-GENERATED DOCUMENTATION AND CLASS.
/**
 * This class provides the ability to make remote calls to the backing service through method calls
 * that map to API methods. Sample code to get started:
 *
 * <pre>{@code
 * // This snippet has been automatically generated and should be regarded as a code template only.
 * // It will require modifications to work:
 * // - It may require correct/in-range values for request initialization.
 * // - It may require specifying regional endpoints when creating the service client as shown in
 * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 * try (MessagingClient messagingClient = MessagingClient.create()) {
 *   String displayName = "displayName1714148973";
 *   String description = "description-1724546052";
 *   Room response = messagingClient.createRoom(displayName, description);
 * }
 * }</pre>
 *
 * <p>Note: close() needs to be called on the MessagingClient object to clean up resources such as
 * threads. In the example above, try-with-resources is used, which automatically calls close().
 *
 * <table>
 *    <tr>
 *      <th>Method</th>
 *      <th>Description</th>
 *      <th>Method Variants</th>
 *    <tr>
 *      <td>CreateRoom</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>createRoom(CreateRoomRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>createRoom(String displayName, String description)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>createRoomCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>GetRoom</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>getRoom(GetRoomRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>getRoom(RoomName name)
 *           <li>getRoom(String name)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>getRoomCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>UpdateRoom</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>updateRoom(UpdateRoomRequest request)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>updateRoomCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>DeleteRoom</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>deleteRoom(DeleteRoomRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>deleteRoom(RoomName name)
 *           <li>deleteRoom(String name)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>deleteRoomCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>ListRooms</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>listRooms(ListRoomsRequest request)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>listRoomsPagedCallable()
 *           <li>listRoomsCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>CreateBlurb</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>createBlurb(CreateBlurbRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>createBlurb(ProfileName parent, ByteString image)
 *           <li>createBlurb(ProfileName parent, String text)
 *           <li>createBlurb(RoomName parent, ByteString image)
 *           <li>createBlurb(RoomName parent, String text)
 *           <li>createBlurb(String parent, ByteString image)
 *           <li>createBlurb(String parent, String text)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>createBlurbCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>GetBlurb</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>getBlurb(GetBlurbRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>getBlurb(BlurbName name)
 *           <li>getBlurb(String name)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>getBlurbCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>UpdateBlurb</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>updateBlurb(UpdateBlurbRequest request)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>updateBlurbCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>DeleteBlurb</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>deleteBlurb(DeleteBlurbRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>deleteBlurb(BlurbName name)
 *           <li>deleteBlurb(String name)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>deleteBlurbCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>ListBlurbs</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>listBlurbs(ListBlurbsRequest request)
 *      </ul>
 *      <p>"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.</p>
 *      <ul>
 *           <li>listBlurbs(ProfileName parent)
 *           <li>listBlurbs(RoomName parent)
 *           <li>listBlurbs(String parent)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>listBlurbsPagedCallable()
 *           <li>listBlurbsCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>SearchBlurbs</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Request object method variants only take one parameter, a request object, which must be constructed before the call.</p>
 *      <ul>
 *           <li>searchBlurbsAsync(SearchBlurbsRequest request)
 *      </ul>
 *      <p>Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.</p>
 *      <ul>
 *           <li>searchBlurbsAsync(String query)
 *      </ul>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>searchBlurbsOperationCallable()
 *           <li>searchBlurbsCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>StreamBlurbs</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>streamBlurbsCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>SendBlurbs</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>sendBlurbsCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    <tr>
 *      <td>Connect</td>
 *      <td><p> </td>
 *      <td>
 *      <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
 *      <ul>
 *           <li>connectCallable()
 *      </ul>
 *       </td>
 *    </tr>
 *    </tr>
 *  </table>
 *
 * <p>See the individual methods for example code.
 *
 * <p>Many parameters require resource names to be formatted in a particular way. To assist with
 * these names, this class includes a format method for each type of name, and additionally a parse
 * method to extract the individual identifiers contained within names that are returned.
 *
 * <p>This class can be customized by passing in a custom instance of MessagingSettings to create().
 * For example:
 *
 * <p>To customize credentials:
 *
 * <pre>{@code
 * // This snippet has been automatically generated and should be regarded as a code template only.
 * // It will require modifications to work:
 * // - It may require correct/in-range values for request initialization.
 * // - It may require specifying regional endpoints when creating the service client as shown in
 * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 * MessagingSettings messagingSettings =
 *     MessagingSettings.newBuilder()
 *         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
 *         .build();
 * MessagingClient messagingClient = MessagingClient.create(messagingSettings);
 * }</pre>
 *
 * <p>To customize the endpoint:
 *
 * <pre>{@code
 * // This snippet has been automatically generated and should be regarded as a code template only.
 * // It will require modifications to work:
 * // - It may require correct/in-range values for request initialization.
 * // - It may require specifying regional endpoints when creating the service client as shown in
 * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 * MessagingSettings messagingSettings =
 *     MessagingSettings.newBuilder().setEndpoint(myEndpoint).build();
 * MessagingClient messagingClient = MessagingClient.create(messagingSettings);
 * }</pre>
 *
 * <p>Please refer to the GitHub repository's samples for more quickstart code snippets.
 */
@BetaApi
@Generated("by gapic-generator-java")
public class MessagingClient implements BackgroundResource {
  private final MessagingSettings settings;
  private final MessagingStub stub;
  private final OperationsClient operationsClient;

  /** Constructs an instance of MessagingClient with default settings. */
  public static final MessagingClient create() throws IOException {
    return create(MessagingSettings.newBuilder().build());
  }

  /**
   * Constructs an instance of MessagingClient, using the given settings. The channels are created
   * based on the settings passed in, or defaults for any settings that are not set.
   */
  public static final MessagingClient create(MessagingSettings settings) throws IOException {
    return new MessagingClient(settings);
  }

  /**
   * Constructs an instance of MessagingClient, using the given stub for making calls. This is for
   * advanced usage - prefer using create(MessagingSettings).
   */
  public static final MessagingClient create(MessagingStub stub) {
    return new MessagingClient(stub);
  }

  /**
   * Constructs an instance of MessagingClient, using the given settings. This is protected so that
   * it is easy to make a subclass, but otherwise, the static factory methods should be preferred.
   */
  protected MessagingClient(MessagingSettings settings) throws IOException {
    this.settings = settings;
    this.stub = ((MessagingStubSettings) settings.getStubSettings()).createStub();
    this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
  }

  protected MessagingClient(MessagingStub stub) {
    this.settings = null;
    this.stub = stub;
    this.operationsClient = OperationsClient.create(this.stub.getOperationsStub());
  }

  public final MessagingSettings getSettings() {
    return settings;
  }

  public MessagingStub getStub() {
    return stub;
  }

  /**
   * Returns the OperationsClient that can be used to query the status of a long-running operation
   * returned by another API method call.
   */
  public final OperationsClient getOperationsClient() {
    return operationsClient;
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String displayName = "displayName1714148973";
   *   String description = "description-1724546052";
   *   Room response = messagingClient.createRoom(displayName, description);
   * }
   * }</pre>
   *
   * @param displayName
   * @param description
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room createRoom(String displayName, String description) {
    CreateRoomRequest request =
        CreateRoomRequest.newBuilder()
            .setRoom(
                Room.newBuilder().setDisplayName(displayName).setDescription(description).build())
            .build();
    return createRoom(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   CreateRoomRequest request =
   *       CreateRoomRequest.newBuilder().setRoom(Room.newBuilder().build()).build();
   *   Room response = messagingClient.createRoom(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room createRoom(CreateRoomRequest request) {
    return createRoomCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   CreateRoomRequest request =
   *       CreateRoomRequest.newBuilder().setRoom(Room.newBuilder().build()).build();
   *   ApiFuture<Room> future = messagingClient.createRoomCallable().futureCall(request);
   *   // Do something.
   *   Room response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<CreateRoomRequest, Room> createRoomCallable() {
    return stub.createRoomCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   RoomName name = RoomName.of("[ROOM]");
   *   Room response = messagingClient.getRoom(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room getRoom(RoomName name) {
    GetRoomRequest request =
        GetRoomRequest.newBuilder().setName(name == null ? null : name.toString()).build();
    return getRoom(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String name = RoomName.of("[ROOM]").toString();
   *   Room response = messagingClient.getRoom(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room getRoom(String name) {
    GetRoomRequest request = GetRoomRequest.newBuilder().setName(name).build();
    return getRoom(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   GetRoomRequest request =
   *       GetRoomRequest.newBuilder().setName(RoomName.of("[ROOM]").toString()).build();
   *   Room response = messagingClient.getRoom(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room getRoom(GetRoomRequest request) {
    return getRoomCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   GetRoomRequest request =
   *       GetRoomRequest.newBuilder().setName(RoomName.of("[ROOM]").toString()).build();
   *   ApiFuture<Room> future = messagingClient.getRoomCallable().futureCall(request);
   *   // Do something.
   *   Room response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<GetRoomRequest, Room> getRoomCallable() {
    return stub.getRoomCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   UpdateRoomRequest request =
   *       UpdateRoomRequest.newBuilder().setRoom(Room.newBuilder().build()).build();
   *   Room response = messagingClient.updateRoom(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Room updateRoom(UpdateRoomRequest request) {
    return updateRoomCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   UpdateRoomRequest request =
   *       UpdateRoomRequest.newBuilder().setRoom(Room.newBuilder().build()).build();
   *   ApiFuture<Room> future = messagingClient.updateRoomCallable().futureCall(request);
   *   // Do something.
   *   Room response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<UpdateRoomRequest, Room> updateRoomCallable() {
    return stub.updateRoomCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   RoomName name = RoomName.of("[ROOM]");
   *   messagingClient.deleteRoom(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteRoom(RoomName name) {
    DeleteRoomRequest request =
        DeleteRoomRequest.newBuilder().setName(name == null ? null : name.toString()).build();
    deleteRoom(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String name = RoomName.of("[ROOM]").toString();
   *   messagingClient.deleteRoom(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteRoom(String name) {
    DeleteRoomRequest request = DeleteRoomRequest.newBuilder().setName(name).build();
    deleteRoom(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   DeleteRoomRequest request =
   *       DeleteRoomRequest.newBuilder().setName(RoomName.of("[ROOM]").toString()).build();
   *   messagingClient.deleteRoom(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteRoom(DeleteRoomRequest request) {
    deleteRoomCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   DeleteRoomRequest request =
   *       DeleteRoomRequest.newBuilder().setName(RoomName.of("[ROOM]").toString()).build();
   *   ApiFuture<Empty> future = messagingClient.deleteRoomCallable().futureCall(request);
   *   // Do something.
   *   future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<DeleteRoomRequest, Empty> deleteRoomCallable() {
    return stub.deleteRoomCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListRoomsRequest request =
   *       ListRoomsRequest.newBuilder()
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   for (Room element : messagingClient.listRooms(request).iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final ListRoomsPagedResponse listRooms(ListRoomsRequest request) {
    return listRoomsPagedCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListRoomsRequest request =
   *       ListRoomsRequest.newBuilder()
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   ApiFuture<Room> future = messagingClient.listRoomsPagedCallable().futureCall(request);
   *   // Do something.
   *   for (Room element : future.get().iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   */
  public final UnaryCallable<ListRoomsRequest, ListRoomsPagedResponse> listRoomsPagedCallable() {
    return stub.listRoomsPagedCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListRoomsRequest request =
   *       ListRoomsRequest.newBuilder()
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   while (true) {
   *     ListRoomsResponse response = messagingClient.listRoomsCallable().call(request);
   *     for (Room element : response.getRoomsList()) {
   *       // doThingsWith(element);
   *     }
   *     String nextPageToken = response.getNextPageToken();
   *     if (!Strings.isNullOrEmpty(nextPageToken)) {
   *       request = request.toBuilder().setPageToken(nextPageToken).build();
   *     } else {
   *       break;
   *     }
   *   }
   * }
   * }</pre>
   */
  public final UnaryCallable<ListRoomsRequest, ListRoomsResponse> listRoomsCallable() {
    return stub.listRoomsCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ProfileName parent = ProfileName.of("[USER]");
   *   ByteString image = ByteString.EMPTY;
   *   Blurb response = messagingClient.createBlurb(parent, image);
   * }
   * }</pre>
   *
   * @param parent
   * @param image
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(ProfileName parent, ByteString image) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent == null ? null : parent.toString())
            .setBlurb(Blurb.newBuilder().setImage(image).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ProfileName parent = ProfileName.of("[USER]");
   *   String text = "text3556653";
   *   Blurb response = messagingClient.createBlurb(parent, text);
   * }
   * }</pre>
   *
   * @param parent
   * @param text
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(ProfileName parent, String text) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent == null ? null : parent.toString())
            .setBlurb(Blurb.newBuilder().setText(text).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   RoomName parent = RoomName.of("[ROOM]");
   *   ByteString image = ByteString.EMPTY;
   *   Blurb response = messagingClient.createBlurb(parent, image);
   * }
   * }</pre>
   *
   * @param parent
   * @param image
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(RoomName parent, ByteString image) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent == null ? null : parent.toString())
            .setBlurb(Blurb.newBuilder().setImage(image).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   RoomName parent = RoomName.of("[ROOM]");
   *   String text = "text3556653";
   *   Blurb response = messagingClient.createBlurb(parent, text);
   * }
   * }</pre>
   *
   * @param parent
   * @param text
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(RoomName parent, String text) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent == null ? null : parent.toString())
            .setBlurb(Blurb.newBuilder().setText(text).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String parent = ProfileName.of("[USER]").toString();
   *   ByteString image = ByteString.EMPTY;
   *   Blurb response = messagingClient.createBlurb(parent, image);
   * }
   * }</pre>
   *
   * @param parent
   * @param image
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(String parent, ByteString image) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent)
            .setBlurb(Blurb.newBuilder().setImage(image).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String parent = ProfileName.of("[USER]").toString();
   *   String text = "text3556653";
   *   Blurb response = messagingClient.createBlurb(parent, text);
   * }
   * }</pre>
   *
   * @param parent
   * @param text
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(String parent, String text) {
    CreateBlurbRequest request =
        CreateBlurbRequest.newBuilder()
            .setParent(parent)
            .setBlurb(Blurb.newBuilder().setText(text).build())
            .build();
    return createBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   CreateBlurbRequest request =
   *       CreateBlurbRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setBlurb(Blurb.newBuilder().build())
   *           .build();
   *   Blurb response = messagingClient.createBlurb(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb createBlurb(CreateBlurbRequest request) {
    return createBlurbCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   CreateBlurbRequest request =
   *       CreateBlurbRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setBlurb(Blurb.newBuilder().build())
   *           .build();
   *   ApiFuture<Blurb> future = messagingClient.createBlurbCallable().futureCall(request);
   *   // Do something.
   *   Blurb response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<CreateBlurbRequest, Blurb> createBlurbCallable() {
    return stub.createBlurbCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   BlurbName name = BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]");
   *   Blurb response = messagingClient.getBlurb(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb getBlurb(BlurbName name) {
    GetBlurbRequest request =
        GetBlurbRequest.newBuilder().setName(name == null ? null : name.toString()).build();
    return getBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String name =
   *       BlurbName.ofUserLegacyUserBlurbName("[USER]", "[LEGACY_USER]", "[BLURB]").toString();
   *   Blurb response = messagingClient.getBlurb(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb getBlurb(String name) {
    GetBlurbRequest request = GetBlurbRequest.newBuilder().setName(name).build();
    return getBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   GetBlurbRequest request =
   *       GetBlurbRequest.newBuilder()
   *           .setName(BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]").toString())
   *           .build();
   *   Blurb response = messagingClient.getBlurb(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb getBlurb(GetBlurbRequest request) {
    return getBlurbCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   GetBlurbRequest request =
   *       GetBlurbRequest.newBuilder()
   *           .setName(BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]").toString())
   *           .build();
   *   ApiFuture<Blurb> future = messagingClient.getBlurbCallable().futureCall(request);
   *   // Do something.
   *   Blurb response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<GetBlurbRequest, Blurb> getBlurbCallable() {
    return stub.getBlurbCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   UpdateBlurbRequest request =
   *       UpdateBlurbRequest.newBuilder().setBlurb(Blurb.newBuilder().build()).build();
   *   Blurb response = messagingClient.updateBlurb(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final Blurb updateBlurb(UpdateBlurbRequest request) {
    return updateBlurbCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   UpdateBlurbRequest request =
   *       UpdateBlurbRequest.newBuilder().setBlurb(Blurb.newBuilder().build()).build();
   *   ApiFuture<Blurb> future = messagingClient.updateBlurbCallable().futureCall(request);
   *   // Do something.
   *   Blurb response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<UpdateBlurbRequest, Blurb> updateBlurbCallable() {
    return stub.updateBlurbCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   BlurbName name = BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]");
   *   messagingClient.deleteBlurb(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteBlurb(BlurbName name) {
    DeleteBlurbRequest request =
        DeleteBlurbRequest.newBuilder().setName(name == null ? null : name.toString()).build();
    deleteBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String name =
   *       BlurbName.ofUserLegacyUserBlurbName("[USER]", "[LEGACY_USER]", "[BLURB]").toString();
   *   messagingClient.deleteBlurb(name);
   * }
   * }</pre>
   *
   * @param name
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteBlurb(String name) {
    DeleteBlurbRequest request = DeleteBlurbRequest.newBuilder().setName(name).build();
    deleteBlurb(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   DeleteBlurbRequest request =
   *       DeleteBlurbRequest.newBuilder()
   *           .setName(BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]").toString())
   *           .build();
   *   messagingClient.deleteBlurb(request);
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final void deleteBlurb(DeleteBlurbRequest request) {
    deleteBlurbCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   DeleteBlurbRequest request =
   *       DeleteBlurbRequest.newBuilder()
   *           .setName(BlurbName.ofRoomBlurbName("[ROOM]", "[BLURB]").toString())
   *           .build();
   *   ApiFuture<Empty> future = messagingClient.deleteBlurbCallable().futureCall(request);
   *   // Do something.
   *   future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<DeleteBlurbRequest, Empty> deleteBlurbCallable() {
    return stub.deleteBlurbCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ProfileName parent = ProfileName.of("[USER]");
   *   for (Blurb element : messagingClient.listBlurbs(parent).iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   *
   * @param parent
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final ListBlurbsPagedResponse listBlurbs(ProfileName parent) {
    ListBlurbsRequest request =
        ListBlurbsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build();
    return listBlurbs(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   RoomName parent = RoomName.of("[ROOM]");
   *   for (Blurb element : messagingClient.listBlurbs(parent).iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   *
   * @param parent
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final ListBlurbsPagedResponse listBlurbs(RoomName parent) {
    ListBlurbsRequest request =
        ListBlurbsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build();
    return listBlurbs(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String parent = ProfileName.of("[USER]").toString();
   *   for (Blurb element : messagingClient.listBlurbs(parent).iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   *
   * @param parent
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final ListBlurbsPagedResponse listBlurbs(String parent) {
    ListBlurbsRequest request = ListBlurbsRequest.newBuilder().setParent(parent).build();
    return listBlurbs(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListBlurbsRequest request =
   *       ListBlurbsRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   for (Blurb element : messagingClient.listBlurbs(request).iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final ListBlurbsPagedResponse listBlurbs(ListBlurbsRequest request) {
    return listBlurbsPagedCallable().call(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListBlurbsRequest request =
   *       ListBlurbsRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   ApiFuture<Blurb> future = messagingClient.listBlurbsPagedCallable().futureCall(request);
   *   // Do something.
   *   for (Blurb element : future.get().iterateAll()) {
   *     // doThingsWith(element);
   *   }
   * }
   * }</pre>
   */
  public final UnaryCallable<ListBlurbsRequest, ListBlurbsPagedResponse> listBlurbsPagedCallable() {
    return stub.listBlurbsPagedCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ListBlurbsRequest request =
   *       ListBlurbsRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   while (true) {
   *     ListBlurbsResponse response = messagingClient.listBlurbsCallable().call(request);
   *     for (Blurb element : response.getBlurbsList()) {
   *       // doThingsWith(element);
   *     }
   *     String nextPageToken = response.getNextPageToken();
   *     if (!Strings.isNullOrEmpty(nextPageToken)) {
   *       request = request.toBuilder().setPageToken(nextPageToken).build();
   *     } else {
   *       break;
   *     }
   *   }
   * }
   * }</pre>
   */
  public final UnaryCallable<ListBlurbsRequest, ListBlurbsResponse> listBlurbsCallable() {
    return stub.listBlurbsCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   String query = "query107944136";
   *   SearchBlurbsResponse response = messagingClient.searchBlurbsAsync(query).get();
   * }
   * }</pre>
   *
   * @param query
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final OperationFuture<SearchBlurbsResponse, SearchBlurbsMetadata> searchBlurbsAsync(
      String query) {
    SearchBlurbsRequest request = SearchBlurbsRequest.newBuilder().setQuery(query).build();
    return searchBlurbsAsync(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   SearchBlurbsRequest request =
   *       SearchBlurbsRequest.newBuilder()
   *           .setQuery("query107944136")
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   SearchBlurbsResponse response = messagingClient.searchBlurbsAsync(request).get();
   * }
   * }</pre>
   *
   * @param request The request object containing all of the parameters for the API call.
   * @throws com.google.api.gax.rpc.ApiException if the remote call fails
   */
  public final OperationFuture<SearchBlurbsResponse, SearchBlurbsMetadata> searchBlurbsAsync(
      SearchBlurbsRequest request) {
    return searchBlurbsOperationCallable().futureCall(request);
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   SearchBlurbsRequest request =
   *       SearchBlurbsRequest.newBuilder()
   *           .setQuery("query107944136")
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   OperationFuture<SearchBlurbsResponse, SearchBlurbsMetadata> future =
   *       messagingClient.searchBlurbsOperationCallable().futureCall(request);
   *   // Do something.
   *   SearchBlurbsResponse response = future.get();
   * }
   * }</pre>
   */
  public final OperationCallable<SearchBlurbsRequest, SearchBlurbsResponse, SearchBlurbsMetadata>
      searchBlurbsOperationCallable() {
    return stub.searchBlurbsOperationCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   SearchBlurbsRequest request =
   *       SearchBlurbsRequest.newBuilder()
   *           .setQuery("query107944136")
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setPageSize(883849137)
   *           .setPageToken("pageToken873572522")
   *           .build();
   *   ApiFuture<Operation> future = messagingClient.searchBlurbsCallable().futureCall(request);
   *   // Do something.
   *   Operation response = future.get();
   * }
   * }</pre>
   */
  public final UnaryCallable<SearchBlurbsRequest, Operation> searchBlurbsCallable() {
    return stub.searchBlurbsCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   StreamBlurbsRequest request =
   *       StreamBlurbsRequest.newBuilder().setName(ProfileName.of("[USER]").toString()).build();
   *   ServerStream<StreamBlurbsResponse> stream =
   *       messagingClient.streamBlurbsCallable().call(request);
   *   for (StreamBlurbsResponse response : stream) {
   *     // Do something when a response is received.
   *   }
   * }
   * }</pre>
   */
  public final ServerStreamingCallable<StreamBlurbsRequest, StreamBlurbsResponse>
      streamBlurbsCallable() {
    return stub.streamBlurbsCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   ApiStreamObserver<CreateBlurbRequest> responseObserver =
   *       new ApiStreamObserver<CreateBlurbRequest>() {
   *         {@literal @}Override
   *         public void onNext(SendBlurbsResponse response) {
   *           // Do something when a response is received.
   *         }
   *
   *         {@literal @}Override
   *         public void onError(Throwable t) {
   *           // Add error-handling
   *         }
   *
   *         {@literal @}Override
   *         public void onCompleted() {
   *           // Do something when complete.
   *         }
   *       };
   *   ApiStreamObserver<CreateBlurbRequest> requestObserver =
   *       messagingClient.sendBlurbs().clientStreamingCall(responseObserver);
   *   CreateBlurbRequest request =
   *       CreateBlurbRequest.newBuilder()
   *           .setParent(ProfileName.of("[USER]").toString())
   *           .setBlurb(Blurb.newBuilder().build())
   *           .build();
   *   requestObserver.onNext(request);
   * }
   * }</pre>
   */
  public final ClientStreamingCallable<CreateBlurbRequest, SendBlurbsResponse>
      sendBlurbsCallable() {
    return stub.sendBlurbsCallable();
  }

  // AUTO-GENERATED DOCUMENTATION AND METHOD.
  /**
   * Sample code:
   *
   * <pre>{@code
   * // This snippet has been automatically generated and should be regarded as a code template only.
   * // It will require modifications to work:
   * // - It may require correct/in-range values for request initialization.
   * // - It may require specifying regional endpoints when creating the service client as shown in
   * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
   * try (MessagingClient messagingClient = MessagingClient.create()) {
   *   BidiStream<ConnectRequest, StreamBlurbsResponse> bidiStream =
   *       messagingClient.connectCallable().call();
   *   ConnectRequest request = ConnectRequest.newBuilder().build();
   *   bidiStream.send(request);
   *   for (StreamBlurbsResponse response : bidiStream) {
   *     // Do something when a response is received.
   *   }
   * }
   * }</pre>
   */
  public final BidiStreamingCallable<ConnectRequest, StreamBlurbsResponse> connectCallable() {
    return stub.connectCallable();
  }

  @Override
  public final void close() {
    stub.close();
  }

  @Override
  public void shutdown() {
    stub.shutdown();
  }

  @Override
  public boolean isShutdown() {
    return stub.isShutdown();
  }

  @Override
  public boolean isTerminated() {
    return stub.isTerminated();
  }

  @Override
  public void shutdownNow() {
    stub.shutdownNow();
  }

  @Override
  public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
    return stub.awaitTermination(duration, unit);
  }

  public static class ListRoomsPagedResponse
      extends AbstractPagedListResponse<
          ListRoomsRequest, ListRoomsResponse, Room, ListRoomsPage, ListRoomsFixedSizeCollection> {

    public static ApiFuture<ListRoomsPagedResponse> createAsync(
        PageContext<ListRoomsRequest, ListRoomsResponse, Room> context,
        ApiFuture<ListRoomsResponse> futureResponse) {
      ApiFuture<ListRoomsPage> futurePage =
          ListRoomsPage.createEmptyPage().createPageAsync(context, futureResponse);
      return ApiFutures.transform(
          futurePage, input -> new ListRoomsPagedResponse(input), MoreExecutors.directExecutor());
    }

    private ListRoomsPagedResponse(ListRoomsPage page) {
      super(page, ListRoomsFixedSizeCollection.createEmptyCollection());
    }
  }

  public static class ListRoomsPage
      extends AbstractPage<ListRoomsRequest, ListRoomsResponse, Room, ListRoomsPage> {

    private ListRoomsPage(
        PageContext<ListRoomsRequest, ListRoomsResponse, Room> context,
        ListRoomsResponse response) {
      super(context, response);
    }

    private static ListRoomsPage createEmptyPage() {
      return new ListRoomsPage(null, null);
    }

    @Override
    protected ListRoomsPage createPage(
        PageContext<ListRoomsRequest, ListRoomsResponse, Room> context,
        ListRoomsResponse response) {
      return new ListRoomsPage(context, response);
    }

    @Override
    public ApiFuture<ListRoomsPage> createPageAsync(
        PageContext<ListRoomsRequest, ListRoomsResponse, Room> context,
        ApiFuture<ListRoomsResponse> futureResponse) {
      return super.createPageAsync(context, futureResponse);
    }
  }

  public static class ListRoomsFixedSizeCollection
      extends AbstractFixedSizeCollection<
          ListRoomsRequest, ListRoomsResponse, Room, ListRoomsPage, ListRoomsFixedSizeCollection> {

    private ListRoomsFixedSizeCollection(List<ListRoomsPage> pages, int collectionSize) {
      super(pages, collectionSize);
    }

    private static ListRoomsFixedSizeCollection createEmptyCollection() {
      return new ListRoomsFixedSizeCollection(null, 0);
    }

    @Override
    protected ListRoomsFixedSizeCollection createCollection(
        List<ListRoomsPage> pages, int collectionSize) {
      return new ListRoomsFixedSizeCollection(pages, collectionSize);
    }
  }

  public static class ListBlurbsPagedResponse
      extends AbstractPagedListResponse<
          ListBlurbsRequest,
          ListBlurbsResponse,
          Blurb,
          ListBlurbsPage,
          ListBlurbsFixedSizeCollection> {

    public static ApiFuture<ListBlurbsPagedResponse> createAsync(
        PageContext<ListBlurbsRequest, ListBlurbsResponse, Blurb> context,
        ApiFuture<ListBlurbsResponse> futureResponse) {
      ApiFuture<ListBlurbsPage> futurePage =
          ListBlurbsPage.createEmptyPage().createPageAsync(context, futureResponse);
      return ApiFutures.transform(
          futurePage, input -> new ListBlurbsPagedResponse(input), MoreExecutors.directExecutor());
    }

    private ListBlurbsPagedResponse(ListBlurbsPage page) {
      super(page, ListBlurbsFixedSizeCollection.createEmptyCollection());
    }
  }

  public static class ListBlurbsPage
      extends AbstractPage<ListBlurbsRequest, ListBlurbsResponse, Blurb, ListBlurbsPage> {

    private ListBlurbsPage(
        PageContext<ListBlurbsRequest, ListBlurbsResponse, Blurb> context,
        ListBlurbsResponse response) {
      super(context, response);
    }

    private static ListBlurbsPage createEmptyPage() {
      return new ListBlurbsPage(null, null);
    }

    @Override
    protected ListBlurbsPage createPage(
        PageContext<ListBlurbsRequest, ListBlurbsResponse, Blurb> context,
        ListBlurbsResponse response) {
      return new ListBlurbsPage(context, response);
    }

    @Override
    public ApiFuture<ListBlurbsPage> createPageAsync(
        PageContext<ListBlurbsRequest, ListBlurbsResponse, Blurb> context,
        ApiFuture<ListBlurbsResponse> futureResponse) {
      return super.createPageAsync(context, futureResponse);
    }
  }

  public static class ListBlurbsFixedSizeCollection
      extends AbstractFixedSizeCollection<
          ListBlurbsRequest,
          ListBlurbsResponse,
          Blurb,
          ListBlurbsPage,
          ListBlurbsFixedSizeCollection> {

    private ListBlurbsFixedSizeCollection(List<ListBlurbsPage> pages, int collectionSize) {
      super(pages, collectionSize);
    }

    private static ListBlurbsFixedSizeCollection createEmptyCollection() {
      return new ListBlurbsFixedSizeCollection(null, 0);
    }

    @Override
    protected ListBlurbsFixedSizeCollection createCollection(
        List<ListBlurbsPage> pages, int collectionSize) {
      return new ListBlurbsFixedSizeCollection(pages, collectionSize);
    }
  }
}