env_logger::init();

let flags = App::new("Hello Client")

.version("0.1")

.author("Tim <[email protected]>")

.about("Say hello!")

.arg(

Arg::with_name("server_addr")

.long("server_addr")

.value_name("ADDRESS")

.help("Sets the server address to connect to.")

.required(true)

.takes_value(true),

)

.arg(

Arg::with_name("name")

.short("n")

.long("name")

.value_name("STRING")

.help("Sets the name to say hello to.")

.required(true)

.takes_value(true),

)

.get_matches();

let server_addr = flags.value_of("server_addr").unwrap();

let server_addr = server_addr

.parse::<SocketAddr>()

.unwrap_or_else(|e| panic!(r#"--server_addr value "{}" invalid: {}"#, server_addr, e));

let name = flags.value_of("name").unwrap().into();

let mut transport = tarpc::serde_transport::tcp::connect(server_addr, Json::default);

transport.config_mut().max_frame_length(usize::MAX);

// WorldClient is generated by the service attribute. It has a constructor `new` that takes a

// config and any Transport as input.

let client = uncode::rpc_service::world::WorldClient::new(client::Config::default(), transport.await?).spawn()?;

// The client has an RPC method for each RPC defined in the annotated trait. It takes the same

// args as defined, with the addition of a Context, which is always the first arg. The Context

// specifies a deadline and trace information which can be helpful in debugging requests.

let hello = client.hello(context::current(), name).await?;

println!("{}", hello);

Ok(())