Searched refs:getServerCallHandler (Results 1 – 11 of 11) 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()
145 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()151 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()170 getMethod(intercepted, "basic/flow").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()175 getMethod(intercepted, "basic/flow2").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()197 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in callNextTwice()240 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in ordered()282 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in orderedForward()308 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in argumentsPassed()420 .getServerCallHandler() in typedMarshalledMessages()497 serverMethod.getServerCallHandler().startCall(serverCall, headers).onMessage("TestMessage"); in distinctMarshallerForRequestAndResponse()
80 assertSame(methodHandler1, serverMethod.getServerCallHandler()); in addMethod_twoArg()82 assertSame(methodHandler2, serverMethod.getServerCallHandler()); in addMethod_twoArg()
53 public ServerCallHandler<ReqT, RespT> getServerCallHandler() { in getServerCallHandler() method in ServerMethodDefinition
243 ServerCallHandler<ReqT, RespT> callHandler = method.getServerCallHandler(); in wrapAndAddMethod()277 definition.getServerCallHandler(), in wrapMethod()
86 .getServerCallHandler() in startCall()
81 binlogInterceptor, binDef.getServerCallHandler()); in wrapMethodDefinition()
588 return new ServerCallParameters<>(call, methodDef.getServerCallHandler()); in streamCreatedInternal()675 ServerCallHandler<ReqT, RespT> handler = methodDef.getServerCallHandler(); in wrapMethod()
299 return methodDef.getServerCallHandler().startCall(serverCall, new Metadata()); in startServerCallHelper()
1485 oMethodDef.getServerCallHandler())); in binaryLogInstalled()