mt_service 0.9.0

Request/reply service primitives for Minot.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use log::{error, info};
use mt_pubsub::{Node, NodeConfig};
use mt_service::ServiceClient;
use ros2_interfaces_jazzy_rkyv::std_msgs::msg;
use std::sync::Arc;
use tokio::time::{self, Duration};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    mt_sea::init_logging();

    let node = Arc::new(Node::create(NodeConfig::new("client")).await?);
    let client: ServiceClient<msg::String, msg::String> =
        ServiceClient::new(node.clone(), "my_cool_service".to_owned()).await?;

    loop {
        let req = msg::String {
            data: "very bad words".to_owned(),
        };

        info!("Sending request: {}", req.data);
        match client.request(req, Some(Duration::from_secs(10))).await {
            Ok(res) => {
                info!("Got response: {}", res.data);
            }
            Err(e) => {
                error!("Service error: {}", e);
                break;
            }
        }

        time::sleep(Duration::from_secs(5)).await;
    }

    Ok(())
}