#[tokio::main]
async fn main() {
    let address = "127.0.0.1:4222".parse().unwrap();
    let client = Client::new(vec![address]);
    client.connect().await;

    let rpc_client_srv = rpc::RpcClient::new(client.clone());
    let rpc_client = ServiceBuilder::new()
        .buffer(100)
        .concurrency_limit(100)
        .service(rpc_client_srv.clone());

    println!("Started!");
    let sc = ShipmentClient {
        rpc_client: rpc_client,
    };
    let req = ShipmentRequest::new();
    let mut res: Shipments = sc.search(req).await.unwrap();
    let mut shipment: Shipment = res.take_records().pop().unwrap();
    println!("Response: {:?}", shipment);
}