1pub mod comm;
6pub mod device;
7
8pub use comm::{DataReader, Packet, PacketVariant};
10pub use device::DeviceConfig;
11
12#[cfg(test)]
13mod tests {
14 use super::*;
15
16 #[tokio::test]
23 async fn test_build_stream_and_parse() {
24 let config = DeviceConfig::default()
25 .with_adapter("hci0".to_string())
26 .with_name("MyndBand".to_string())
27 .with_channel(5);
28 let stream = config
29 .connect()
30 .await
31 .expect("Failed to build RFCOMM stream");
32 println!("Local address: {:?}", stream.as_ref().local_addr().unwrap());
33 println!("Remote address: {:?}", stream.peer_addr().unwrap());
34 println!("Security: {:?}", stream.as_ref().security().unwrap());
35 let mut data_reader = DataReader::new(stream);
36 let packet = data_reader
37 .poll_next()
38 .await
39 .expect("Failed to poll next packet");
40 println!("{:?}", packet);
41 }
42}