| /external/sdk-platform-java/gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/ |
| D | GrpcDirectStreamController.java | 53 private final ClientCall<RequestT, ResponseT> clientCall; field in GrpcDirectStreamController
62 ClientCall<RequestT, ResponseT> clientCall, ResponseObserver<ResponseT> responseObserver) { in GrpcDirectStreamController()
67 ClientCall<RequestT, ResponseT> clientCall, in GrpcDirectStreamController()
|
| D | GrpcDirectCallable.java | 60 ClientCall<RequestT, ResponseT> clientCall = GrpcClientCalls.newCall(descriptor, inputContext); in futureCall() local
|
| D | GrpcClientCalls.java | 112 ClientCall<RequestT, ResponseT> clientCall, RequestT request) { in eagerFutureUnaryCall()
|
| /external/grpc-grpc-java/gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/ |
| D | ConditionalClientInterceptorTest.java | 74 ClientCall<?, ?> clientCall = conditionalClientInterceptor.interceptCall(method, in predicateFalse() local
86 ClientCall<?, ?> clientCall = conditionalClientInterceptor.interceptCall(method, in predicateTrue() local
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/grpcproxy/ |
| D | GrpcProxy.java | 69 ClientCall<ReqT, RespT> clientCall in startCall() local
82 public CallProxy(ServerCall<ReqT, RespT> serverCall, ClientCall<ReqT, RespT> clientCall) { in CallProxy()
88 private final ClientCall<ReqT, ?> clientCall; field in GrpcProxy.CallProxy.RequestProxy
92 public RequestProxy(ClientCall<ReqT, ?> clientCall) { in RequestProxy()
|
| /external/sdk-platform-java/gax-java/gax-httpjson/src/main/java/com/google/api/gax/httpjson/ |
| D | HttpJsonDirectStreamController.java | 44 private final HttpJsonClientCall<RequestT, ResponseT> clientCall; field in HttpJsonDirectStreamController
52 HttpJsonClientCall<RequestT, ResponseT> clientCall, in HttpJsonDirectStreamController()
|
| D | HttpJsonDirectCallable.java | 66 HttpJsonClientCall<RequestT, ResponseT> clientCall = in futureCall() local
|
| D | HttpJsonClientCalls.java | 80 HttpJsonClientCall<RequestT, ResponseT> clientCall, RequestT request) { in futureUnaryCall()
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/ |
| D | TimeoutTest.java | 328 ClientCall<String, String> clientCall = Mockito.mock(ClientCall.class); in setupUnaryCallable() local
389 ClientCall<String, String> clientCall = Mockito.mock(ClientCall.class); in setupServerStreamingCallable() local
|
| D | GrpcLongRunningTest.java | 225 ClientCall<Integer, ?> clientCall = new MockClientCall<>(results[0], status); in mockResponse() local
|
| D | ChannelPoolTest.java | 137 final ClientCall<Color, Money> clientCall = Mockito.mock(ClientCall.class); in ensureEvenDistribution() local
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ForwardingManagedChannelTest.java | 89 NoopClientCall<Void, Void> clientCall = new NoopClientCall<>(); in newCall() local
|
| D | ConfigSelectingClientCallTest.java | 174 TestCall<ReqT, RespT> clientCall = new TestCall<>(callOptions); in newCall() local
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | BinaryLogProviderTest.java | 146 ClientCall<String, Integer> clientCall = wChannel.newCall(method, CallOptions.DEFAULT); in wrapChannel_handler() local
|
| /external/grpc-grpc-java/gcp-observability/src/test/java/io/grpc/gcp/observability/ |
| D | GcpObservabilityTest.java | 102 ClientCall<?, ?> clientCall = conditionalClientInterceptor.interceptCall(method, in conditionalInterceptor() local
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 685 final ClientCall<Integer, Integer> clientCall = channel.newCall(BIDI_STREAMING_METHOD, in inprocessTransportInboundFlowControl() local
767 final ClientCall<Integer, Integer> clientCall = channel.newCall(BIDI_STREAMING_METHOD, in inprocessTransportOutboundFlowControl() local
|
| D | ServerCallsTest.java | 568 final ClientCall<Integer, Integer> clientCall = channel.newCall(STREAMING_METHOD, in inprocessTransportManualFlow() local
|
| /external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| D | XdsNameResolverTest.java | 1141 ClientCall<Void, Void> clientCall = interceptor.interceptCall( in assertCallSelectClusterResult() local
1169 ClientCall<Void, Void> clientCall = interceptor.interceptCall( in assertCallSelectRlsPluginResult() local
|