Home
last modified time | relevance | path

Searched refs:SimpleForwardingServerCall (Results 1 – 14 of 14) sorted by relevance

/external/grpc-grpc-java/api/src/main/java/io/grpc/
DForwardingServerCall.java44 public abstract static class SimpleForwardingServerCall<ReqT, RespT> class in ForwardingServerCall
49 protected SimpleForwardingServerCall(ServerCall<ReqT, RespT> delegate) { in SimpleForwardingServerCall() method in ForwardingServerCall.SimpleForwardingServerCall
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java20 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
45 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/orca/
DOrcaMetricReportingServerInterceptor.java24 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
93 new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DDataPlaneRule.java19 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
138 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) { in startServer()
/external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/
DGrpcResponseMetadataTest.java41 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
110 new SimpleForwardingServerCall<ReqT, RespT>(call) { in setUp()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java22 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
525 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
553 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
580 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
DXdsTestServer.java21 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
296 ServerCall<ReqT, RespT> newCall = new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/
DInternalLoggingServerInterceptor.java23 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
134 new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/
DBinderChannelSmokeTest.java38 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
354 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java122 ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT> {
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DBinaryLogProviderTest.java32 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
356 ServerCall<ReqT, RespT> wCall = new SimpleForwardingServerCall<ReqT, RespT>(call) {
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DServerInterceptorsTest.java358 .SimpleForwardingServerCall<ReqT, RespT>(call) { in typedMarshalledMessages()
387 .SimpleForwardingServerCall<ReqT, RespT>(call) { in typedMarshalledMessages()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DBinlogHelper.java41 import io.grpc.ForwardingServerCall.SimpleForwardingServerCall;
522 ServerCall<ReqT, RespT> wCall = new SimpleForwardingServerCall<ReqT, RespT>(call) {
/external/grpc-grpc-java/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/
DSafeMethodCachingInterceptorTest.java91 new ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT>(call) {