#[tokio::main]
async fn main() {
    let config = zenoh::Config::default();
    let session = zenoh::open(config).await.unwrap();
    let subscriber = session.declare_subscriber("test").await.unwrap();

    loop {
        let sample = subscriber.recv_async().await.unwrap();
        let payload = sample.payload();
        let bytes: Vec<u8> = payload.into();
        let message: zenoh_exp::Message = ciborium::from_reader(&bytes[..]).unwrap();

        println!(
            "Kind: {} Key: {} Value: {:?}",
            sample.kind(),
            sample.key_expr().as_str(),
            message
        );
    }
}