Home
last modified time | relevance | path

Searched refs:ServerCallHandler (Results 1 – 25 of 36) sorted by relevance

12

/external/grpc-grpc-java/core/src/main/java/io/grpc/
DServerMethodDefinition.java26 private final ServerCallHandler<ReqT, RespT> handler;
29 ServerCallHandler<ReqT, RespT> handler) { in ServerMethodDefinition()
43 ServerCallHandler<ReqT, RespT> handler) { in create()
53 public ServerCallHandler<ReqT, RespT> getServerCallHandler() { in getServerCallHandler()
64 ServerCallHandler<ReqT, RespT> handler) { in withServerCallHandler()
DServerInterceptors.java203 ServerCallHandler<ReqT, RespT> callHandler = method.getServerCallHandler(); in wrapAndAddMethod()
210 static final class InterceptCallHandler<ReqT, RespT> implements ServerCallHandler<ReqT, RespT> {
212 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in create()
217 private final ServerCallHandler<ReqT, RespT> callHandler;
220 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in InterceptCallHandler()
236 final ServerCallHandler<WReqT, WRespT> wrappedHandler = wrapHandler( in wrapMethod()
243 private static <OReqT, ORespT, WReqT, WRespT> ServerCallHandler<WReqT, WRespT> wrapHandler( in wrapHandler()
244 final ServerCallHandler<OReqT, ORespT> originalHandler, in wrapHandler()
247 return new ServerCallHandler<WReqT, WRespT>() { in wrapHandler()
DInternalServerInterceptors.java24 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandler( in interceptCallHandler()
25 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandler()
36 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandlerCreate( in interceptCallHandlerCreate()
37 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandlerCreate()
DServerCallHandler.java26 public interface ServerCallHandler<RequestT, ResponseT> { interface
DServerInterceptor.java53 ServerCallHandler<ReqT, RespT> next); in interceptCall()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DServerInterceptorsTest.java59 private ServerCallHandler<String, Integer> handler;
144 ServerCallHandler<String, Integer> handler2 = mock(ServerCallHandler.class); in correctHandlerCalled()
171 ServerCallHandler<ReqT, RespT> next) { in callNextTwice()
188 handler = new ServerCallHandler<String, Integer>() { in ordered()
202 ServerCallHandler<ReqT, RespT> next) { in ordered()
212 ServerCallHandler<ReqT, RespT> next) { in ordered()
230 handler = new ServerCallHandler<String, Integer>() { in orderedForward()
244 ServerCallHandler<ReqT, RespT> next) { in orderedForward()
254 ServerCallHandler<ReqT, RespT> next) { in orderedForward()
282 ServerCallHandler<R1, R2> next) { in argumentsPassed()
[all …]
DServerServiceDefinitionTest.java46 private ServerCallHandler<String, Integer> methodHandler1
48 private ServerCallHandler<String, Integer> methodHandler2
155 implements ServerCallHandler<ReqT, RespT> {
DContextsTest.java87 new ServerCallHandler<Object, Object>() { in interceptCall_basic()
112 interceptCall(uniqueContext, call, headers, new ServerCallHandler<Object, Object>() { in interceptCall_restoresIfNextThrows()
150 new ServerCallHandler<Object, Object>() { in interceptCall_restoresIfListenerThrows()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java27 import io.grpc.ServerCallHandler;
49 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncUnaryCall( in asyncUnaryCall()
59 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncServerStreamingCall( in asyncServerStreamingCall()
69 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncClientStreamingCall( in asyncClientStreamingCall()
79 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncBidiStreamingCall( in asyncBidiStreamingCall()
105 implements ServerCallHandler<ReqT, RespT> {
202 private static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncUnaryRequestCall( in asyncUnaryRequestCall()
208 implements ServerCallHandler<ReqT, RespT> {
290 private static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncStreamingRequestCall( in asyncStreamingRequestCall()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java32 import io.grpc.ServerCallHandler;
91 ServerCallHandler<Integer, Integer> callHandler = in runtimeStreamObserverIsServerCallStreamObserver()
141 ServerCallHandler<Integer, Integer> callHandler = in cannotSetOnCancelHandlerAfterServiceInvocation()
169 ServerCallHandler<Integer, Integer> callHandler = in cannotSetOnReadyHandlerAfterServiceInvocation()
197 ServerCallHandler<Integer, Integer> callHandler = in cannotDisableAutoFlowControlAfterServiceInvocation()
219 ServerCallHandler<Integer, Integer> callHandler = in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
242 ServerCallHandler<Integer, Integer> callHandler = in disablingInboundAutoFlowControlForUnaryHasNoEffect()
261 ServerCallHandler<Integer, Integer> callHandler = in onReadyHandlerCalledForUnaryRequest()
297 ServerCallHandler<Integer, Integer> callHandler = in clientSendsOne_errorMissingRequest_unary()
315 ServerCallHandler<Integer, Integer> callHandler = in clientSendsOne_errorMissingRequest_serverStreaming()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DMutableHandlerRegistryTest.java30 import io.grpc.ServerCallHandler;
55 private ServerCallHandler<String, Integer> flowHandler;
58 private ServerCallHandler<String, Integer> coupleHandler;
61 private ServerCallHandler<String, Integer> fewHandler;
64 private ServerCallHandler<String, Integer> otherFlowHandler;
142 ServerCallHandler<?, ?> handler = registry.lookupMethod("basic/flow").getServerCallHandler(); in multiServiceLookup()
DUtilServerInterceptorsTest.java25 import io.grpc.ServerCallHandler;
51 private ServerCallHandler<Void, Void> handler = new ServerCallHandler<Void, Void>() {
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderClientInterceptorTest.java30 import io.grpc.ServerCallHandler;
70 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) {
100 Matchers.<ServerCallHandler<HelloRequest, HelloReply>>any()); in clientHeaderDeliveredToServer()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java23 import io.grpc.ServerCallHandler;
43 ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DHandlerRegistryBenchmark.java23 import io.grpc.ServerCallHandler;
81 new ServerCallHandler<Void, Void>() { in setup()
DAbstractBenchmark.java27 import io.grpc.ServerCallHandler;
265 .addMethod(unaryMethod, new ServerCallHandler<ByteBuf, ByteBuf>() { in setup()
296 .addMethod(pingPongMethod, new ServerCallHandler<ByteBuf, ByteBuf>() { in setup()
329 .addMethod(flowControlledStreaming, new ServerCallHandler<ByteBuf, ByteBuf>() { in setup()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/
DTestUtils.java22 import io.grpc.ServerCallHandler;
59 ServerCallHandler<ReqT, RespT> next) { in recordRequestHeadersInterceptor()
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinaryLogProvider.java33 import io.grpc.ServerCallHandler;
79 ServerCallHandler<byte[], byte[]> binlogHandler = in wrapMethodDefinition()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java68 import io.grpc.ServerCallHandler;
193 private ServerCallHandler<String, Integer> callHandler;
475 new ServerCallHandler<String, Integer>() { in basicExchangeHelper()
651 ServerCallHandler<ReqT, RespT> next) { in interceptors()
667 ServerCallHandler<ReqT, RespT> next) { in interceptors()
678 ServerCallHandler<String, Integer> callHandler = new ServerCallHandler<String, Integer>() { in interceptors()
733 new ServerCallHandler<String, Integer>() { in exceptionInStartCallPropagatesToStream()
855 new ServerCallHandler<String, Integer>() { in testCallContextIsBoundInListenerCallbacks()
960 new ServerCallHandler<String, Integer>() { in testClientClose_setup()
1247 ServerCallHandler<ReqT, RespT> next) { in binaryLogInstalled()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java25 import io.grpc.ServerCallHandler;
514 ServerCallHandler<ReqT, RespT> next) {
542 ServerCallHandler<ReqT, RespT> next) {
569 ServerCallHandler<ReqT, RespT> next) {
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java40 import io.grpc.ServerCallHandler;
213 new ServerCallHandler<String, Integer>() { in wrapMethodDefinition_methodDescriptor()
233 new ServerCallHandler<String, Integer>() { in wrapMethodDefinition_handler()
351 ServerCallHandler<ReqT, RespT> next) {
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java27 import io.grpc.ServerCallHandler;
58 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DAltsServerBuilder.java30 import io.grpc.ServerCallHandler;
228 ServerCallHandler<ReqT, RespT> nextHandler) { in interceptCall()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadServer.java29 import io.grpc.ServerCallHandler;
197 private class GenericServiceCallHandler implements ServerCallHandler<ByteBuf, ByteBuf> {
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java38 import io.grpc.ServerCallHandler;
95 Metadata headers, ServerCallHandler<ReqT, RespT> next) { in getServerBuilder()

12