Home
last modified time | relevance | path

Searched refs:callHandler (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java91 ServerCallHandler<Integer, Integer> callHandler = in runtimeStreamObserverIsServerCallStreamObserver() local
117 callHandler.startCall(serverCall, new Metadata()); in runtimeStreamObserverIsServerCallStreamObserver()
141 ServerCallHandler<Integer, Integer> callHandler = in cannotSetOnCancelHandlerAfterServiceInvocation() local
151 callHandler.startCall(serverCall, new Metadata()); in cannotSetOnCancelHandlerAfterServiceInvocation()
169 ServerCallHandler<Integer, Integer> callHandler = in cannotSetOnReadyHandlerAfterServiceInvocation() local
179 callHandler.startCall(serverCall, new Metadata()); in cannotSetOnReadyHandlerAfterServiceInvocation()
197 ServerCallHandler<Integer, Integer> callHandler = in cannotDisableAutoFlowControlAfterServiceInvocation() local
207 callHandler.startCall(serverCall, new Metadata()); in cannotDisableAutoFlowControlAfterServiceInvocation()
219 ServerCallHandler<Integer, Integer> callHandler = in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages() local
231 callHandler.startCall(serverCall, new Metadata()); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DServerInterceptors.java203 ServerCallHandler<ReqT, RespT> callHandler = method.getServerCallHandler(); in wrapAndAddMethod() local
205 callHandler = InterceptCallHandler.create(interceptor, callHandler); in wrapAndAddMethod()
207 serviceDefBuilder.addMethod(method.withServerCallHandler(callHandler)); in wrapAndAddMethod()
212 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in create() argument
213 return new InterceptCallHandler<ReqT, RespT>(interceptor, callHandler); in create()
217 private final ServerCallHandler<ReqT, RespT> callHandler; field in ServerInterceptors.InterceptCallHandler
220 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in InterceptCallHandler() argument
222 this.callHandler = callHandler; in InterceptCallHandler()
229 return interceptor.interceptCall(call, headers, callHandler); in startCall()
DInternalServerInterceptors.java25 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandler() argument
26 return ServerInterceptors.InterceptCallHandler.create(interceptor, callHandler); in interceptCallHandler()
37 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandlerCreate() argument
38 return ServerInterceptors.InterceptCallHandler.create(interceptor, callHandler); in interceptCallHandlerCreate()
/external/grpc-grpc/src/csharp/Grpc.Core/
DServer.cs341 IServerCallHandler callHandler; in HandleCallAsync()
342 if (!callHandlers.TryGetValue(newRpc.Method, out callHandler)) in HandleCallAsync()
344 callHandler = UnimplementedMethodCallHandler.Instance; in HandleCallAsync()
346 await callHandler.HandleCall(newRpc, cq).ConfigureAwait(false); in HandleCallAsync()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java193 private ServerCallHandler<String, Integer> callHandler; field in ServerImplTest
678 ServerCallHandler<String, Integer> callHandler = new ServerCallHandler<String, Integer>() { in interceptors() local
690 .addMethod(METHOD, callHandler).build()); in interceptors()
1071 .addMethod(METHOD, callHandler).build()); in handlerRegistryPriorities()
1086 verify(callHandler).startCall(Matchers.<ServerCall<String, Integer>>anyObject(), in handlerRegistryPriorities()
1094 verifyNoMoreInteractions(callHandler); in handlerRegistryPriorities()