Home
last modified time | relevance | path

Searched refs:SimpleForwardingClientCall (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc-java/api/src/main/java/io/grpc/
DForwardingClientCall.java44 public abstract static class SimpleForwardingClientCall<ReqT, RespT> class in ForwardingClientCall
48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall() method in ForwardingClientCall.SimpleForwardingClientCall
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderClientInterceptor.java24 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
44 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DMetadataUtils.java27 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
85 extends SimpleForwardingClientCall<ReqT, RespT> {
156 extends SimpleForwardingClientCall<ReqT, RespT> {
/external/sdk-platform-java/gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/
DGrpcMetadataHandlerInterceptor.java37 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
62 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in interceptCall()
DGrpcHeaderInterceptor.java38 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
81 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in interceptCall()
DChannelPool.java39 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
521 static class ReleasingClientCall<ReqT, RespT> extends SimpleForwardingClientCall<ReqT, RespT> {
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderServerInterceptorTest.java29 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
97 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in serverHeaderDeliveredToClient()
/external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/testing/
DLocalChannelProvider.java44 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
193 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DFakeControlPlaneXdsIntegrationTest.java36 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
153 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
/external/grpc-grpc-java/gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/
DInternalLoggingChannelInterceptor.java29 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
108 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DClientInterceptorsTest.java37 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
252 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in addOutboundHeaders()
283 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in examineInboundHeaders()
319 return new SimpleForwardingClientCall<ReqT, RespT>(call) { }; in normalCall()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientCallTest.java32 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
215 Runnable r = delayedClientCall.setCall(new SimpleForwardingClientCall<String, Integer>( in delayedCallsRunUnderContext()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCompressionTest.java36 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
288 private class ClientCompressor<ReqT, RespT> extends SimpleForwardingClientCall<ReqT, RespT> {
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/
DOrcaMetricReportingServerInterceptorTest.java28 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
290 extends SimpleForwardingClientCall<ReqT, RespT> {
/external/grpc-grpc-java/census/src/main/java/io/grpc/census/
DCensusTracingModule.java31 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
486 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in interceptCall()
DCensusStatsModule.java34 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
806 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DBinaryLogProviderTest.java30 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
310 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
/external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/
DSafeMethodCachingInterceptor.java173 return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DXdsTestClient.java33 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
323 return new SimpleForwardingClientCall<ReqT, RespT>(call) { in runQps()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DBinlogHelper.java39 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
407 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in getClientInterceptor()
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
DXdsNameResolver.java37 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
465 return new SimpleForwardingClientCall<ReqT, RespT>( in selectConfig()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java37 import io.grpc.ForwardingClientCall.SimpleForwardingClientCall;
962 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()