ProtobufRpcClient.java 文件源码

public static <RequestT extends Message, ResponseT extends Message> RpcMethod<RequestT, ResponseT> create(
        ServiceDescriptor descriptor, String methodName, RequestT requestDefaultInstance,
        ResponseT responseDefaultInstance) {
    MethodDescriptor method = descriptor.findMethodByName(methodName);
    Preconditions.checkArgument(method != null);

    Preconditions.checkArgument(requestDefaultInstance.getDescriptorForType() == method.getInputType());
    Preconditions.checkArgument(responseDefaultInstance.getDescriptorForType() == method.getOutputType());

    return new RpcMethod<RequestT, ResponseT>(method, responseDefaultInstance);
}