use futures::StreamExt;
use ip_roam::Connection;
use std::io::{Error, ErrorKind, Result};
use std::pin::pin;
#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<()> {
let c = Connection::new()?;
tokio::spawn(c.conn);
let mut s = pin!(c.handle.addresses.stream());
while let Some(addr) = s.next().await {
println!("current: {:?}", addr);
}
let mut s = pin!(c.handle.monitor.stream());
while let Some(item) = s.next().await {
println!("monitor: {:?}", item);
}
Err(Error::from(ErrorKind::ConnectionAborted))
}