Crate cbor_protocol
source · [−]Expand description
Kubos CBOR over UDP communication crate
Examples
use cbor_protocol::*;
use serde_cbor::ser;
use std::time::Duration;
let cbor_connection = Protocol::new(&"0.0.0.0:8000".to_owned(), 4096);
let message = ser::to_vec_packed(&("hello", "world")).unwrap();
cbor_connection.send_message(&message, "0.0.0.0:8001".parse().unwrap()).unwrap();
match cbor_connection.recv_message_peer_timeout(Duration::from_millis(10)) {
Ok((source, message)) => {
println!("Received message from {:?}: {:?}", source, message);
}
Err(ProtocolError::Timeout) => println!("Timed out waiting for reply"),
Err(err) => eprintln!("Failed to receive message: {}", err)
}
Structs
CBOR protocol communication structure
Enums
An error generated during protocol execution