use async_labjack::client::LabjackClient;
use async_labjack::TEST;
use tokio::net::TcpSocket;
use tokio::time::Duration;
#[tokio::main()]
async fn main() {
env_logger::init();
let socket_addr = "192.168.42.100:502".parse().unwrap();
let custom_socket = TcpSocket::new_v4().unwrap();
custom_socket.set_recv_buffer_size(1024).unwrap();
let client = &mut LabjackClient::connect_socket_with_timeout(
custom_socket,
socket_addr,
Duration::from_millis(3000),
)
.await
.unwrap();
let value = TEST.read(client).await.unwrap();
assert_eq!(value, 0x00112233);
println!("Success! Disconnecting...");
client.disconnect().await.unwrap();
}