use neato_xv11;
use std::sync::mpsc::channel;

// Create a message channel.
let (message_tx, message_rx) = channel();
// Create a command channel.
let (command_tx, command_rx) = channel();

thread::spawn(move || {
    neato_xv11::run("/dev/serial0", message_tx, command_rx);
});

// Receive a message from the LIDAR.
match self.message_rx.try_recv() {
    Ok(r) => {
        match r {
            Ok(message) => println!(message),
            Err(error) => println!(error),
        }
    }
    Err(e) => {
        match e {
            // Data not ready, do nothing.
            TryRecvError::Empty => println!("No items detected yet"),
            // Channel disconnected, stop running.
            TryRecvError::Disconnected => println!("Disconnected"),
        }
    }
}