Searched refs:getServerCallHandler (Results 1 – 10 of 10) sorted by relevance
114 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onMessage(null); in statusRuntimeExceptionTransmitter()115 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onCancel(); in statusRuntimeExceptionTransmitter()116 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onComplete(); in statusRuntimeExceptionTransmitter()117 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onHalfClose(); in statusRuntimeExceptionTransmitter()118 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onReady(); in statusRuntimeExceptionTransmitter()149 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers); in statusRuntimeExceptionTransmitterIgnoresClosedCalls()167 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers); in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
142 ServerCallHandler<?, ?> handler = registry.lookupMethod("basic/flow").getServerCallHandler(); in multiServiceLookup()144 handler = registry.lookupMethod("multi/couple").getServerCallHandler(); in multiServiceLookup()146 handler = registry.lookupMethod("multi/few").getServerCallHandler(); in multiServiceLookup()
128 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()134 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()153 getMethod(intercepted, "basic/flow").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()158 getMethod(intercepted, "basic/flow2").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()180 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in callNextTwice()223 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in ordered()265 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in orderedForward()292 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in argumentsPassed()404 .getServerCallHandler() in typedMarshalledMessages()
78 assertSame(methodHandler1, serverMethod.getServerCallHandler()); in addMethod_twoArg()80 assertSame(methodHandler2, serverMethod.getServerCallHandler()); in addMethod_twoArg()
53 public ServerCallHandler<ReqT, RespT> getServerCallHandler() { in getServerCallHandler() method in ServerMethodDefinition
203 ServerCallHandler<ReqT, RespT> callHandler = method.getServerCallHandler(); in wrapAndAddMethod()237 definition.getServerCallHandler(), in wrapMethod()
81 binlogInterceptor, binDef.getServerCallHandler()); in wrapMethodDefinition()
537 ServerCallHandler<ReqT, RespT> handler = methodDef.getServerCallHandler(); in startCall()563 methodDef.getServerCallHandler().startCall(call, headers); in startWrappedCall()
301 return methodDef.getServerCallHandler().startCall(serverCall, new Metadata()); in startServerCallHelper()
1266 oMethodDef.getServerCallHandler())); in binaryLogInstalled()