| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ServerMethodDefinition.java | 28 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()
|
| D | ServerInterceptor.java | 51 ServerCall<ReqT, RespT> call, in interceptCall()
53 ServerCallHandler<ReqT, RespT> next); in interceptCall()
|
| D | ServerServiceDefinition.java | 101 MethodDescriptor<ReqT, RespT> method, ServerCallHandler<ReqT, RespT> handler) { in addMethod()
108 public <ReqT, RespT> Builder addMethod(ServerMethodDefinition<ReqT, RespT> def) { in addMethod()
|
| D | InternalServerInterceptors.java | 24 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandler( in interceptCallHandler()
36 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandlerCreate( in interceptCallHandlerCreate()
|
| D | ServerInterceptors.java | 201 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()
|
| D | Contexts.java | 46 ServerCall<ReqT, RespT> call, in interceptCall()
48 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
|
| D | ServerStreamTracer.java | 96 ServerCallInfo<ReqT, RespT> callInfo) { in create()
100 private ReadOnlyServerCall(ServerCallInfo<ReqT, RespT> callInfo) { in ReadOnlyServerCall()
|
| D | ClientInterceptor.java | 51 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next); in interceptCall()
|
| D | BinaryLog.java | 29 ServerMethodDefinition<ReqT, RespT> oMethodDef); in wrapMethodDefinition()
|
| D | ForwardingServerCall.java | 44 protected SimpleForwardingServerCall(ServerCall<ReqT, RespT> delegate) { in SimpleForwardingServerCall()
|
| D | ForwardingClientCall.java | 48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 50 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 …]
|
| D | ClientCalls.java | 62 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 …]
|
| D | MetadataUtils.java | 73 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/ |
| D | HeaderServerInterceptor.java | 41 ServerCall<ReqT, RespT> call, in interceptCall()
43 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
|
| D | HeaderClientInterceptor.java | 42 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method, in interceptCall()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | CompressionTest.java | 262 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/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 58 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinaryLogProvider.java | 69 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in wrapMethodDefinition()
146 MethodDescriptor<ReqT, RespT> method, in interceptCall()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | AltsServerBuilder.java | 226 ServerCall<ReqT, RespT> serverCall, in interceptCall()
228 ServerCallHandler<ReqT, RespT> nextHandler) { in interceptCall()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinaryLogProviderTest.java | 288 final ServerMethodDefinition<ReqT, RespT> methodDef, in startServerCallHelper()
307 final MethodDescriptor<ReqT, RespT> method, in interceptCall()
|
| /external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/ |
| D | ClientAuthInterceptor.java | 62 final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, final Channel next) { in interceptCall()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerCallImpl.java | 67 ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method, in ServerCallImpl()
233 ServerCallImpl<ReqT, ?> call, ServerCall.Listener<ReqT> listener, in ServerStreamListenerImpl()
|
| D | ServerCallInfoImpl.java | 34 MethodDescriptor<ReqT, RespT> methodDescriptor, in ServerCallInfoImpl()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
| D | HeaderServerInterceptorTest.java | 96 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in serverHeaderDeliveredToClient()
|