| /external/sdk-platform-java/gapic-generator-java/src/test/java/com/google/api/generator/gapic/composer/grpcrest/goldens/ |
| D | WickedClientTest.golden | 8 import com.google.api.gax.grpc.testing.MockStreamObserver;
114 MockStreamObserver<EvilResponse> responseObserver = new MockStreamObserver<>();
135 MockStreamObserver<EvilResponse> responseObserver = new MockStreamObserver<>();
161 MockStreamObserver<EvilResponse> responseObserver = new MockStreamObserver<>();
181 MockStreamObserver<EvilResponse> responseObserver = new MockStreamObserver<>();
|
| D | EchoClientTest.golden | 11 import com.google.api.gax.grpc.testing.MockStreamObserver;
422 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
442 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
806 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
831 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
|
| /external/google-cloud-java/java-video-intelligence/google-cloud-video-intelligence/src/test/java/com/google/cloud/videointelligence/v1p3beta1/ |
| D | StreamingVideoIntelligenceServiceClientTest.java | 23 import com.google.api.gax.grpc.testing.MockStreamObserver;
93 MockStreamObserver<StreamingAnnotateVideoResponse> responseObserver = in streamingAnnotateVideoTest()
94 new MockStreamObserver<>(); in streamingAnnotateVideoTest()
115 MockStreamObserver<StreamingAnnotateVideoResponse> responseObserver = in streamingAnnotateVideoExceptionTest()
116 new MockStreamObserver<>(); in streamingAnnotateVideoExceptionTest()
|
| /external/google-cloud-java/java-mediatranslation/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/ |
| D | SpeechTranslationServiceClientTest.java | 23 import com.google.api.gax.grpc.testing.MockStreamObserver;
92 MockStreamObserver<StreamingTranslateSpeechResponse> responseObserver = in streamingTranslateSpeechTest()
93 new MockStreamObserver<>(); in streamingTranslateSpeechTest()
114 MockStreamObserver<StreamingTranslateSpeechResponse> responseObserver = in streamingTranslateSpeechExceptionTest()
115 new MockStreamObserver<>(); in streamingTranslateSpeechExceptionTest()
|
| /external/sdk-platform-java/test/integration/goldens/apigeeconnect/src/com/google/cloud/apigeeconnect/v1/ |
| D | TetherClientTest.java | 23 import com.google.api.gax.grpc.testing.MockStreamObserver;
105 MockStreamObserver<EgressRequest> responseObserver = new MockStreamObserver<>(); in egressTest()
134 MockStreamObserver<EgressRequest> responseObserver = new MockStreamObserver<>(); in egressExceptionTest()
|
| /external/google-cloud-java/java-apigee-connect/google-cloud-apigee-connect/src/test/java/com/google/cloud/apigeeconnect/v1/ |
| D | TetherClientTest.java | 23 import com.google.api.gax.grpc.testing.MockStreamObserver;
105 MockStreamObserver<EgressRequest> responseObserver = new MockStreamObserver<>(); in egressTest()
134 MockStreamObserver<EgressRequest> responseObserver = new MockStreamObserver<>(); in egressExceptionTest()
|
| /external/sdk-platform-java/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/ |
| D | EchoClientTest.java | 28 import com.google.api.gax.grpc.testing.MockStreamObserver;
171 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in expandTest()
191 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in expandExceptionTest()
221 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in collectTest()
245 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in collectExceptionTest()
277 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in chatTest()
301 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>(); in chatExceptionTest()
|
| D | MessagingClientTest.java | 28 import com.google.api.gax.grpc.testing.MockStreamObserver;
1487 MockStreamObserver<StreamBlurbsResponse> responseObserver = new MockStreamObserver<>(); in streamBlurbsTest()
1508 MockStreamObserver<StreamBlurbsResponse> responseObserver = new MockStreamObserver<>(); in streamBlurbsExceptionTest()
1535 MockStreamObserver<SendBlurbsResponse> responseObserver = new MockStreamObserver<>(); in sendBlurbsTest()
1560 MockStreamObserver<SendBlurbsResponse> responseObserver = new MockStreamObserver<>(); in sendBlurbsExceptionTest()
1586 MockStreamObserver<StreamBlurbsResponse> responseObserver = new MockStreamObserver<>(); in connectTest()
1606 MockStreamObserver<StreamBlurbsResponse> responseObserver = new MockStreamObserver<>(); in connectExceptionTest()
|
| /external/sdk-platform-java/gapic-generator-java/src/test/java/com/google/api/generator/gapic/composer/grpc/goldens/ |
| D | EchoClientTest.golden | 11 import com.google.api.gax.grpc.testing.MockStreamObserver;
408 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
425 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
456 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
481 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
514 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
539 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
572 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
597 MockStreamObserver<EchoResponse> responseObserver = new MockStreamObserver<>();
|
| D | LoggingClientTest.golden | 14 import com.google.api.gax.grpc.testing.MockStreamObserver;
581 MockStreamObserver<TailLogEntriesResponse> responseObserver = new MockStreamObserver<>();
606 MockStreamObserver<TailLogEntriesResponse> responseObserver = new MockStreamObserver<>();
|
| /external/google-cloud-java/java-speech/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/ |
| D | SpeechClientTest.java | 24 import com.google.api.gax.grpc.testing.MockStreamObserver;
202 MockStreamObserver<StreamingRecognizeResponse> responseObserver = new MockStreamObserver<>(); in streamingRecognizeTest()
223 MockStreamObserver<StreamingRecognizeResponse> responseObserver = new MockStreamObserver<>(); in streamingRecognizeExceptionTest()
|
| /external/google-cloud-java/java-speech/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/ |
| D | SpeechClientTest.java | 24 import com.google.api.gax.grpc.testing.MockStreamObserver;
202 MockStreamObserver<StreamingRecognizeResponse> responseObserver = new MockStreamObserver<>(); in streamingRecognizeTest()
223 MockStreamObserver<StreamingRecognizeResponse> responseObserver = new MockStreamObserver<>(); in streamingRecognizeExceptionTest()
|
| /external/google-cloud-java/java-maps-routing/google-maps-routing/src/test/java/com/google/maps/routing/v2/ |
| D | RoutesClientTest.java | 24 import com.google.api.gax.grpc.testing.MockStreamObserver;
204 MockStreamObserver<RouteMatrixElement> responseObserver = new MockStreamObserver<>(); in computeRouteMatrixTest()
231 MockStreamObserver<RouteMatrixElement> responseObserver = new MockStreamObserver<>(); in computeRouteMatrixExceptionTest()
|
| /external/sdk-platform-java/test/integration/goldens/bigtable/src/com/google/cloud/bigtable/data/v2/ |
| D | BaseBigtableDataClientTest.java | 24 import com.google.api.gax.grpc.testing.MockStreamObserver;
124 MockStreamObserver<ReadRowsResponse> responseObserver = new MockStreamObserver<>(); in readRowsTest()
147 MockStreamObserver<ReadRowsResponse> responseObserver = new MockStreamObserver<>(); in readRowsExceptionTest()
176 MockStreamObserver<SampleRowKeysResponse> responseObserver = new MockStreamObserver<>(); in sampleRowKeysTest()
197 MockStreamObserver<SampleRowKeysResponse> responseObserver = new MockStreamObserver<>(); in sampleRowKeysExceptionTest()
397 MockStreamObserver<MutateRowsResponse> responseObserver = new MockStreamObserver<>(); in mutateRowsTest()
419 MockStreamObserver<MutateRowsResponse> responseObserver = new MockStreamObserver<>(); in mutateRowsExceptionTest()
|
| /external/google-cloud-java/java-dialogflow/google-cloud-dialogflow/src/test/java/com/google/cloud/dialogflow/v2/ |
| D | SessionsClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
213 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentTest()
244 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentExceptionTest()
|
| D | ParticipantsClientTest.java | 27 import com.google.api.gax.grpc.testing.MockStreamObserver;
649 MockStreamObserver<StreamingAnalyzeContentResponse> responseObserver = in streamingAnalyzeContentTest()
650 new MockStreamObserver<>(); in streamingAnalyzeContentTest()
683 MockStreamObserver<StreamingAnalyzeContentResponse> responseObserver = in streamingAnalyzeContentExceptionTest()
684 new MockStreamObserver<>(); in streamingAnalyzeContentExceptionTest()
|
| /external/google-cloud-java/java-dialogflow/google-cloud-dialogflow/src/test/java/com/google/cloud/dialogflow/v2beta1/ |
| D | SessionsClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
217 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentTest()
248 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentExceptionTest()
|
| D | ParticipantsClientTest.java | 28 import com.google.api.gax.grpc.testing.MockStreamObserver;
744 MockStreamObserver<StreamingAnalyzeContentResponse> responseObserver = in streamingAnalyzeContentTest()
745 new MockStreamObserver<>(); in streamingAnalyzeContentTest()
779 MockStreamObserver<StreamingAnalyzeContentResponse> responseObserver = in streamingAnalyzeContentExceptionTest()
780 new MockStreamObserver<>(); in streamingAnalyzeContentExceptionTest()
|
| /external/google-cloud-java/java-dialogflow-cx/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3/ |
| D | SessionsClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
180 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentTest()
212 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentExceptionTest()
|
| /external/google-cloud-java/java-dialogflow-cx/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/ |
| D | SessionsClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
180 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentTest()
212 MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>(); in streamingDetectIntentExceptionTest()
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/testing/ |
| D | MockStreamObserver.java | 40 public class MockStreamObserver<T> implements ApiStreamObserver<T> { class
|
| /external/google-cloud-java/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1/ |
| D | FeaturestoreOnlineServingServiceClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
205 MockStreamObserver<ReadFeatureValuesResponse> responseObserver = new MockStreamObserver<>(); in streamingReadFeatureValuesTest()
229 MockStreamObserver<ReadFeatureValuesResponse> responseObserver = new MockStreamObserver<>(); in streamingReadFeatureValuesExceptionTest()
|
| /external/google-cloud-java/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/ |
| D | FeaturestoreOnlineServingServiceClientTest.java | 26 import com.google.api.gax.grpc.testing.MockStreamObserver;
205 MockStreamObserver<ReadFeatureValuesResponse> responseObserver = new MockStreamObserver<>(); in streamingReadFeatureValuesTest()
229 MockStreamObserver<ReadFeatureValuesResponse> responseObserver = new MockStreamObserver<>(); in streamingReadFeatureValuesExceptionTest()
|
| /external/sdk-platform-java/test/integration/goldens/logging/src/com/google/cloud/logging/v2/ |
| D | LoggingClientTest.java | 30 import com.google.api.gax.grpc.testing.MockStreamObserver;
612 MockStreamObserver<TailLogEntriesResponse> responseObserver = new MockStreamObserver<>(); in tailLogEntriesTest()
638 MockStreamObserver<TailLogEntriesResponse> responseObserver = new MockStreamObserver<>(); in tailLogEntriesExceptionTest()
|
| /external/sdk-platform-java/test/integration/goldens/storage/src/com/google/storage/v2/ |
| D | StorageClientTest.java | 29 import com.google.api.gax.grpc.testing.MockStreamObserver;
1704 MockStreamObserver<ReadObjectResponse> responseObserver = new MockStreamObserver<>(); in readObjectTest()
1734 MockStreamObserver<ReadObjectResponse> responseObserver = new MockStreamObserver<>(); in readObjectExceptionTest()
1831 MockStreamObserver<WriteObjectResponse> responseObserver = new MockStreamObserver<>(); in writeObjectTest()
1858 MockStreamObserver<WriteObjectResponse> responseObserver = new MockStreamObserver<>(); in writeObjectExceptionTest()
|