| /aosp_15_r20/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| H A D | ProtoReflectionServiceTest.java | 181 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilename() local
208 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilenameConsistentForMutableServices() local
250 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbol() local
285 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedSymbol() local
311 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbolForMutableServices() local
357 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingExtension() local
398 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedExtension() local
428 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingExtensionForMutableServices() local
465 StreamObserver<ServerReflectionRequest> requestObserver = in allExtensionNumbersOfType() local
499 StreamObserver<ServerReflectionRequest> requestObserver = in allExtensionNumbersOfTypeForMutableServices() local
[all …]
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| H A D | LoadReportClientTest.java | 219 StreamObserver<LoadStatsRequest> requestObserver = in periodicLoadReporting() local
386 StreamObserver<LoadStatsRequest> requestObserver = lrsRequestObservers.poll(); in lrsStreamClosedAndRetried() local
509 StreamObserver<LoadStatsRequest> requestObserver = in raceBetweenStopAndLoadReporting() local
535 StreamObserver<LoadStatsRequest> requestObserver = in raceBetweenStopAndLrsStreamRetry() local
559 StreamObserver<LoadStatsRequest> requestObserver = lrsRequestObservers.poll(); in raceBetweenLoadReportingAndLrsStreamClosure() local
|
| H A D | CsdsServiceTest.java | 208 StreamObserver<ClientStatusRequest> requestObserver = in streamClientStatus_happyPath() local
230 StreamObserver<ClientStatusRequest> requestObserver = in streamClientStatus_requestInvalid() local
250 StreamObserver<ClientStatusRequest> requestObserver = in streamClientStatus_onClientError() local
|
| /aosp_15_r20/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| H A D | AbstractInteropTest.java | 677 StreamObserver<StreamingInputCallRequest> requestObserver = in clientStreaming() local
713 StreamObserver<StreamingInputCallRequest> requestObserver = in clientCompressedStreaming() local
822 StreamObserver<StreamingOutputCallRequest> requestObserver in pingPong() local
856 StreamObserver<StreamingOutputCallRequest> requestObserver in emptyStream() local
867 StreamObserver<StreamingInputCallRequest> requestObserver = in cancelAfterBegin() local
903 StreamObserver<StreamingOutputCallRequest> requestObserver in cancelAfterFirstResponse() local
1473 StreamObserver<StreamingOutputCallRequest> requestObserver in gracefulShutdown() local
1635 StreamObserver<StreamingOutputCallRequest> requestObserver in statusCodeAndMessage() local
1708 StreamObserver<StreamingOutputCallRequest> requestObserver in timeoutOnSleepingServer() local
|
| /aosp_15_r20/external/sdk-platform-java/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/ |
| H A D | EchoClientTest.java | 224 ApiStreamObserver<EchoRequest> requestObserver = callable.clientStreamingCall(responseObserver); in collectTest() local
248 ApiStreamObserver<EchoRequest> requestObserver = callable.clientStreamingCall(responseObserver); in collectExceptionTest() local
280 ApiStreamObserver<EchoRequest> requestObserver = callable.bidiStreamingCall(responseObserver); in chatTest() local
304 ApiStreamObserver<EchoRequest> requestObserver = callable.bidiStreamingCall(responseObserver); in chatExceptionTest() local
|
| H A D | MockEchoImpl.java | 104 StreamObserver<EchoRequest> requestObserver = in collect() local
140 StreamObserver<EchoRequest> requestObserver = in chat() local
|
| H A D | MockMessagingImpl.java | 310 StreamObserver<CreateBlurbRequest> requestObserver = in sendBlurbs() local
347 StreamObserver<ConnectRequest> requestObserver = in connect() local
|
| H A D | MessagingClientTest.java | 1539 ApiStreamObserver<CreateBlurbRequest> requestObserver = in sendBlurbsTest() local
1564 ApiStreamObserver<CreateBlurbRequest> requestObserver = in sendBlurbsExceptionTest() local
1589 ApiStreamObserver<ConnectRequest> requestObserver = in connectTest() local
1609 ApiStreamObserver<ConnectRequest> requestObserver = in connectExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-mediatranslation/google-cloud-mediatranslation/src/test/java/com/google/cloud/mediatranslation/v1beta1/ |
| H A D | SpeechTranslationServiceClientTest.java | 97 ApiStreamObserver<StreamingTranslateSpeechRequest> requestObserver = in streamingTranslateSpeechTest() local
119 ApiStreamObserver<StreamingTranslateSpeechRequest> requestObserver = in streamingTranslateSpeechExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-video-intelligence/google-cloud-video-intelligence/src/test/java/com/google/cloud/videointelligence/v1p3beta1/ |
| H A D | StreamingVideoIntelligenceServiceClientTest.java | 98 ApiStreamObserver<StreamingAnnotateVideoRequest> requestObserver = in streamingAnnotateVideoTest() local
120 ApiStreamObserver<StreamingAnnotateVideoRequest> requestObserver = in streamingAnnotateVideoExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-apigee-connect/google-cloud-apigee-connect/src/test/java/com/google/cloud/apigeeconnect/v1/ |
| H A D | TetherClientTest.java | 108 ApiStreamObserver<EgressResponse> requestObserver = in egressTest() local
137 ApiStreamObserver<EgressResponse> requestObserver = in egressExceptionTest() local
|
| /aosp_15_r20/external/sdk-platform-java/test/integration/goldens/apigeeconnect/src/com/google/cloud/apigeeconnect/v1/ |
| H A D | TetherClientTest.java | 108 ApiStreamObserver<EgressResponse> requestObserver = in egressTest() local
137 ApiStreamObserver<EgressResponse> requestObserver = in egressExceptionTest() local
|
| /aosp_15_r20/external/sdk-platform-java/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ |
| H A D | ITClientSideStreaming.java | 57 ApiStreamObserver<EchoRequest> requestObserver = in testGrpc_sendStreamedContent_receiveConcatenatedResponse() local
74 ApiStreamObserver<EchoRequest> requestObserver = in testGrpc_sendStreamedContent_handleServerError() local
|
| /aosp_15_r20/external/dagger2/javatests/dagger/grpc/functional/server/ |
| H A D | BaristaTest.java | 114 StreamObserver<CoffeeRequest> requestObserver = in testClientStreamingGetCoffee() local
134 StreamObserver<CoffeeRequest> requestObserver = in testBidiStreamingGetCoffee() local
|
| /aosp_15_r20/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| H A D | ServerCalls.java | 235 StreamObserver<ReqT> requestObserver = method.invoke(responseObserver); in startCall() local
245 private final StreamObserver<ReqT> requestObserver; field in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
252 StreamObserver<ReqT> requestObserver, in StreamingServerCallListener()
|
| /aosp_15_r20/external/google-cloud-java/java-speech/google-cloud-speech/src/test/java/com/google/cloud/speech/v1p1beta1/ |
| H A D | SpeechClientTest.java | 206 ApiStreamObserver<StreamingRecognizeRequest> requestObserver = in streamingRecognizeTest() local
227 ApiStreamObserver<StreamingRecognizeRequest> requestObserver = in streamingRecognizeExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-speech/google-cloud-speech/src/test/java/com/google/cloud/speech/v1/ |
| H A D | SpeechClientTest.java | 206 ApiStreamObserver<StreamingRecognizeRequest> requestObserver = in streamingRecognizeTest() local
227 ApiStreamObserver<StreamingRecognizeRequest> requestObserver = in streamingRecognizeExceptionTest() local
|
| /aosp_15_r20/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| H A D | RouteGuideServerTest.java | 188 StreamObserver<Point> requestObserver = stub.recordRoute(responseObserver); in recordRoute() local
225 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat() local
|
| /aosp_15_r20/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| H A D | RouteGuideClient.java | 155 StreamObserver<Point> requestObserver = asyncStub.recordRoute(responseObserver); in recordRoute() local
193 StreamObserver<RouteNote> requestObserver = in routeChat() local
|
| /aosp_15_r20/external/google-cloud-java/java-dialogflow/google-cloud-dialogflow/src/test/java/com/google/cloud/dialogflow/v2beta1/ |
| H A D | SessionsClientTest.java | 221 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentTest() local
252 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-dialogflow/google-cloud-dialogflow/src/test/java/com/google/cloud/dialogflow/v2/ |
| H A D | SessionsClientTest.java | 217 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentTest() local
248 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-dialogflow-cx/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3/ |
| H A D | SessionsClientTest.java | 184 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentTest() local
216 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentExceptionTest() local
|
| /aosp_15_r20/external/google-cloud-java/java-dialogflow-cx/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/ |
| H A D | SessionsClientTest.java | 184 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentTest() local
216 ApiStreamObserver<StreamingDetectIntentRequest> requestObserver = in streamingDetectIntentExceptionTest() local
|
| /aosp_15_r20/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| H A D | AbstractBenchmark.java | 445 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startStreamingCalls() local
499 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startFlowControlledStreamingCalls() local
|
| /aosp_15_r20/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| H A D | AsyncClient.java | 194 StreamObserver<SimpleRequest> requestObserver = stub.streamingCall(responseObserver); in doStreamingCalls() local
212 StreamObserver<SimpleRequest> requestObserver; field in AsyncClient.ThisIsAHackStreamObserver
|