Home
last modified time | relevance | path

Searched defs:ReqT (Results 1 – 25 of 65) sorted by relevance

123

/external/grpc-grpc-java/api/src/main/java/io/grpc/
DServerMethodDefinition.java28 private ServerMethodDefinition(MethodDescriptor<ReqT, RespT> method, in ServerMethodDefinition()
29 ServerCallHandler<ReqT, RespT> handler) { in ServerMethodDefinition()
42 MethodDescriptor<ReqT, RespT> method, in create()
43 ServerCallHandler<ReqT, RespT> handler) { in create()
64 ServerCallHandler<ReqT, RespT> handler) { in withServerCallHandler()
DServerInterceptor.java56 ServerCall<ReqT, RespT> call, in interceptCall()
58 ServerCallHandler<ReqT, RespT> next); in interceptCall()
DServerServiceDefinition.java99 MethodDescriptor<ReqT, RespT> method, ServerCallHandler<ReqT, RespT> handler) { in addMethod()
106 public <ReqT, RespT> Builder addMethod(ServerMethodDefinition<ReqT, RespT> def) { in addMethod()
DServerInterceptors.java241 ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, in wrapAndAddMethod()
252 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in create()
260 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in InterceptCallHandler()
267 ServerCall<ReqT, RespT> call, in startCall()
DContexts.java46 ServerCall<ReqT, RespT> call, in interceptCall()
48 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
DServerStreamTracer.java96 ServerCallInfo<ReqT, RespT> callInfo) { in create()
100 private ReadOnlyServerCall(ServerCallInfo<ReqT, RespT> callInfo) { in ReadOnlyServerCall()
DServerCallExecutorSupplier.java33 <ReqT, RespT> Executor getExecutor(ServerCall<ReqT, RespT> call, Metadata metadata); in getExecutor()
DClientInterceptor.java60 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next); in interceptCall()
DBinaryLog.java29 ServerMethodDefinition<ReqT, RespT> oMethodDef); in wrapMethodDefinition()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java50 UnaryMethod<ReqT, RespT> method) { in asyncUnaryCall()
60 ServerStreamingMethod<ReqT, RespT> method) { in asyncServerStreamingCall()
70 ClientStreamingMethod<ReqT, RespT> method) { in asyncClientStreamingCall()
80 BidiStreamingMethod<ReqT, RespT> method) { in asyncBidiStreamingCall()
119 UnaryServerCallHandler(UnaryRequestMethod<ReqT, RespT> method, boolean serverStreaming) { in UnaryServerCallHandler()
125 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall()
147 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver, in UnaryServerCallListener()
148 ServerCall<ReqT, RespT> call) { in UnaryServerCallListener()
226 StreamingServerCallHandler(StreamingRequestMethod<ReqT, RespT> method, boolean bidi) { in StreamingServerCallHandler()
232 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall()
[all …]
DClientCalls.java75 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncUnaryCall()
89 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncServerStreamingCall()
105 ClientCall<ReqT, RespT> call, in asyncClientStreamingCall()
121 ClientCall<ReqT, RespT> call, StreamObserver<RespT> responseObserver) { in asyncBidiStreamingCall()
133 public static <ReqT, RespT> RespT blockingUnaryCall(ClientCall<ReqT, RespT> call, ReqT req) { in blockingUnaryCall()
151 Channel channel, MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, ReqT req) { in blockingUnaryCall()
194 ClientCall<ReqT, RespT> call, ReqT req) { in blockingServerStreamingCall()
211 Channel channel, MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, ReqT req) { in blockingServerStreamingCall()
229 ClientCall<ReqT, RespT> call, ReqT req) { in futureUnaryCall()
305 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver, in asyncUnaryRequestCall()
[all …]
DMetadataUtils.java80 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
88 HeaderAttachingClientCall(ClientCall<ReqT, RespT> call) { in HeaderAttachingClientCall()
151 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
159 MetadataCapturingClientCall(ClientCall<ReqT, RespT> call) { in MetadataCapturingClientCall()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java41 ServerCall<ReqT, RespT> call, in interceptCall()
43 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/authz/src/main/java/io/grpc/authz/
DAuthorizationServerInterceptor.java61 ServerCall<ReqT, RespT> call, Metadata headers, in interceptCall()
62 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
DFileWatcherAuthorizationServerInterceptor.java59 ServerCall<ReqT, RespT> call, Metadata headers, in interceptCall()
60 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/examples/example-jwt-auth/src/main/java/io/grpc/examples/jwtauth/
DJwtServerInterceptor.java43 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> serverCall, in interceptCall()
44 Metadata metadata, ServerCallHandler<ReqT, RespT> serverCallHandler) { in interceptCall()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/grpcproxy/
DGrpcProxy.java68 ServerCall<ReqT, RespT> serverCall, Metadata headers) { in startCall()
82 public CallProxy(ServerCall<ReqT, RespT> serverCall, ClientCall<ReqT, RespT> clientCall) { in CallProxy()
92 public RequestProxy(ClientCall<ReqT, ?> clientCall) { in RequestProxy()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCompressionTest.java263 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
278 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
289 protected ClientCompressor(ClientCall<ReqT, RespT> delegate) { in ClientCompressor()
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DGlobalInterceptorsTest.java169 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
177 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java58 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/gcp-observability/src/test/java/io/grpc/gcp/observability/
DGcpObservabilityTest.java244 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
252 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/internal/
DBinderTransportSecurity.java82 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/orca/
DOrcaMetricReportingServerInterceptor.java84 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DBinaryLogProvider.java69 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in wrapMethodDefinition()
146 MethodDescriptor<ReqT, RespT> method, in interceptCall()
/external/sdk-platform-java/gax-java/gax-httpjson/src/main/java/com/google/api/gax/httpjson/
DHttpJsonClientInterceptor.java52 ApiMethodDescriptor<ReqT, RespT> method, in interceptCall()

123