Home
last modified time | relevance | path

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

12

/external/grpc-grpc-java/core/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.java51 ServerCall<ReqT, RespT> call, in interceptCall()
53 ServerCallHandler<ReqT, RespT> next); in interceptCall()
DInternalServerInterceptors.java24 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandler( in interceptCallHandler()
36 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandlerCreate( in interceptCallHandlerCreate()
DServerServiceDefinition.java101 MethodDescriptor<ReqT, RespT> method, ServerCallHandler<ReqT, RespT> handler) { in addMethod()
108 public <ReqT, RespT> Builder addMethod(ServerMethodDefinition<ReqT, RespT> def) { in addMethod()
DServerInterceptors.java201 ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, in wrapAndAddMethod()
212 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in create()
220 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in InterceptCallHandler()
227 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()
DClientInterceptor.java51 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next); in interceptCall()
DForwardingServerCall.java44 protected SimpleForwardingServerCall(ServerCall<ReqT, RespT> delegate) { in SimpleForwardingServerCall()
DBinaryLog.java29 ServerMethodDefinition<ReqT, RespT> oMethodDef); in wrapMethodDefinition()
DForwardingClientCall.java48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall()
/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()
110 UnaryServerCallHandler(UnaryRequestMethod<ReqT, RespT> method) { in UnaryServerCallHandler()
115 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall()
136 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver, in UnaryServerCallListener()
137 ServerCall<ReqT, RespT> call) { in UnaryServerCallListener()
203 UnaryRequestMethod<ReqT, RespT> method) { in asyncUnaryRequestCall()
213 StreamingServerCallHandler(StreamingRequestMethod<ReqT, RespT> method) { in StreamingServerCallHandler()
[all …]
DClientCalls.java62 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncUnaryCall()
72 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncServerStreamingCall()
84 ClientCall<ReqT, RespT> call, in asyncClientStreamingCall()
96 ClientCall<ReqT, RespT> call, StreamObserver<RespT> responseObserver) { in asyncBidiStreamingCall()
106 public static <ReqT, RespT> RespT blockingUnaryCall(ClientCall<ReqT, RespT> call, ReqT req) { in blockingUnaryCall()
123 Channel channel, MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, ReqT req) { in blockingUnaryCall()
156 ClientCall<ReqT, RespT> call, ReqT req) { in blockingServerStreamingCall()
171 Channel channel, MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, ReqT req) { in blockingServerStreamingCall()
187 ClientCall<ReqT, RespT> call, ReqT req) { in futureUnaryCall()
263 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver, in asyncUnaryRequestCall()
[all …]
DMetadataUtils.java73 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
81 HeaderAttachingClientCall(ClientCall<ReqT, RespT> call) { in HeaderAttachingClientCall()
137 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
145 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()
DHeaderClientInterceptor.java42 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method, 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/interop-testing/src/test/java/io/grpc/testing/integration/
DCompressionTest.java262 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
277 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall()
288 protected ClientCompressor(ClientCall<ReqT, RespT> delegate) { in ClientCompressor()
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinaryLogProvider.java69 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in wrapMethodDefinition()
146 MethodDescriptor<ReqT, RespT> method, in interceptCall()
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DAltsServerBuilder.java226 ServerCall<ReqT, RespT> serverCall, in interceptCall()
228 ServerCallHandler<ReqT, RespT> nextHandler) { in interceptCall()
/external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/
DClientAuthInterceptor.java62 final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, final Channel next) { in interceptCall()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderServerInterceptorTest.java96 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in serverHeaderDeliveredToClient()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallInfoImpl.java34 MethodDescriptor<ReqT, RespT> methodDescriptor, in ServerCallInfoImpl()
DServerCallImpl.java67 ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method, in ServerCallImpl()
233 ServerCallImpl<ReqT, ?> call, ServerCall.Listener<ReqT> listener, in ServerStreamListenerImpl()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java288 final ServerMethodDefinition<ReqT, RespT> methodDef, in startServerCallHelper()
307 final MethodDescriptor<ReqT, RespT> method, in interceptCall()

12