| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 183 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilename() local
210 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilenameConsistentForMutableServices() local
252 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbol() local
287 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedSymbol() local
313 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbolForMutableServices() local
359 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingExtension() local
400 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedExtension() local
430 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingExtensionForMutableServices() local
467 StreamObserver<ServerReflectionRequest> requestObserver = in allExtensionNumbersOfType() local
501 StreamObserver<ServerReflectionRequest> requestObserver = in allExtensionNumbersOfTypeForMutableServices() local
[all …]
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServerTest.java | 186 StreamObserver<Point> requestObserver = stub.recordRoute(responseObserver); in recordRoute() local
223 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat() local
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClient.java | 164 StreamObserver<Point> requestObserver = asyncStub.recordRoute(responseObserver); in recordRoute() local
202 StreamObserver<RouteNote> requestObserver = in routeChat() local
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 566 StreamObserver<StreamingInputCallRequest> requestObserver = in clientStreaming() local
602 StreamObserver<StreamingInputCallRequest> requestObserver = in clientCompressedStreaming() local
715 StreamObserver<StreamingOutputCallRequest> requestObserver in pingPong() local
749 StreamObserver<StreamingOutputCallRequest> requestObserver in emptyStream() local
758 StreamObserver<StreamingInputCallRequest> requestObserver = in cancelAfterBegin() local
795 StreamObserver<StreamingOutputCallRequest> requestObserver in cancelAfterFirstResponse() local
1368 StreamObserver<StreamingOutputCallRequest> requestObserver in gracefulShutdown() local
1532 StreamObserver<StreamingOutputCallRequest> requestObserver in statusCodeAndMessage() local
1604 StreamObserver<StreamingOutputCallRequest> requestObserver in timeoutOnSleepingServer() local
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 221 StreamObserver<ReqT> requestObserver = method.invoke(responseObserver); in startCall() local
231 private final StreamObserver<ReqT> requestObserver; field in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
238 StreamObserver<ReqT> requestObserver, in StreamingServerCallListener()
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 437 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startStreamingCalls() local
491 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startFlowControlledStreamingCalls() local
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncClient.java | 200 StreamObserver<SimpleRequest> requestObserver = stub.streamingCall(responseObserver); in doStreamingCalls() local
218 StreamObserver<SimpleRequest> requestObserver; field in AsyncClient.ThisIsAHackStreamObserver
|
| /external/grpc-grpc-java/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/ |
| D | RouteGuideActivity.java | 309 StreamObserver<Point> requestObserver = asyncStub.recordRoute(responseObserver); in recordRoute() local
369 StreamObserver<RouteNote> requestObserver = in routeChat() local
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 320 CallStreamObserver<Integer> requestObserver = in callStreamObserverPropagatesFlowControlRequestsToCall() local
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 381 final AtomicReference<StreamObserver<Messages.SimpleRequest>> requestObserver = in run() local
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionService.java | 135 ProtoReflectionStreamObserver requestObserver = in serverReflectionInfo() local
|