// Path: grpc-google-cloud-mediatranslation-v1beta1/src/main/java/com/google/cloud/mediatranslation/v1beta1/SpeechTranslationServiceGrpc.java
// public abstract static class SpeechTranslationServiceImplBase implements io.grpc.BindableService {
// 
//   /**
//    *
//    *
//    * <pre>
//    * Performs bidirectional streaming speech translation: receive results while
//    * sending audio. This method is only available via the gRPC API (not REST).
//    * </pre>
//    */
//   public io.grpc.stub.StreamObserver<
//           com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechRequest>
//       streamingTranslateSpeech(
//           io.grpc.stub.StreamObserver<
//                   com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechResponse>
//               responseObserver) {
//     return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(
//         getStreamingTranslateSpeechMethod(), responseObserver);
//   }
// 
//   @java.lang.Override
//   public final io.grpc.ServerServiceDefinition bindService() {
//     return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
//         .addMethod(
//             getStreamingTranslateSpeechMethod(),
//             io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
//                 new MethodHandlers<
//                     com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechRequest,
//                     com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechResponse>(
//                     this, METHODID_STREAMING_TRANSLATE_SPEECH)))
//         .build();
//   }
// }


import com.google.api.core.BetaApi;
import com.google.cloud.mediatranslation.v1beta1.SpeechTranslationServiceGrpc.SpeechTranslationServiceImplBase;
import com.google.protobuf.AbstractMessage;
import io.grpc.stub.StreamObserver;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Queue;
import javax.annotation.Generated;
/*
 * Copyright 2021 Google LLC
 *
 * 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
 *
 *      https://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.mediatranslation.v1beta1;


@BetaApi
@Generated("by gapic-generator-java")
// Path: grpc-google-cloud-mediatranslation-v1beta1/src/main/java/com/google/cloud/mediatranslation/v1beta1/SpeechTranslationServiceGrpc.java
// public abstract static class SpeechTranslationServiceImplBase implements io.grpc.BindableService {
// 
//   /**
//    *
//    *
//    * <pre>
//    * Performs bidirectional streaming speech translation: receive results while
//    * sending audio. This method is only available via the gRPC API (not REST).
//    * </pre>
//    */
//   public io.grpc.stub.StreamObserver<
//           com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechRequest>
//       streamingTranslateSpeech(
//           io.grpc.stub.StreamObserver<
//                   com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechResponse>
//               responseObserver) {
//     return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(
//         getStreamingTranslateSpeechMethod(), responseObserver);
//   }
// 
//   @java.lang.Override
//   public final io.grpc.ServerServiceDefinition bindService() {
//     return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
//         .addMethod(
//             getStreamingTranslateSpeechMethod(),
//             io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
//                 new MethodHandlers<
//                     com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechRequest,
//                     com.google.cloud.mediatranslation.v1beta1.StreamingTranslateSpeechResponse>(
//                     this, METHODID_STREAMING_TRANSLATE_SPEECH)))
//         .build();
//   }
// }


// Path: google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/MockSpeechTranslationServiceImpl.java
import com.google.api.core.BetaApi;
import com.google.cloud.mediatranslation.v1beta1.SpeechTranslationServiceGrpc.SpeechTranslationServiceImplBase;
import com.google.protobuf.AbstractMessage;
import io.grpc.stub.StreamObserver;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Queue;
import javax.annotation.Generated;

/*
 * Copyright 2021 Google LLC
 *
 * 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
 *
 *      https://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.mediatranslation.v1beta1;


@BetaApi
@Generated("by gapic-generator-java")
public class MockSpeechTranslationServiceImpl extends SpeechTranslationServiceImplBase {