zenoh-exp/src/bin/get.rs

13 lines
379 B
Rust

#[tokio::main]
async fn main() {
let config = zenoh::Config::from_env().unwrap();
let session = zenoh::open(config).await.unwrap();
let replies = session.get("name").await.unwrap();
while let Ok(reply) = replies.recv_async().await {
let result = reply.result().unwrap();
println!("Got: {:?}", result.payload().try_to_string().unwrap());
}
}