Currently works, but a lot of work to do. PRs welcome!
use futures::lock::Mutex;
use log::{info};
use rrtsp_client::client::{Body, Client, Data, Url, Host};
use std::sync::Arc;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init();
let uri_str = "rtsp://admin:[email protected]:10554/tcp/av0_0";
let url = Url::parse(uri_str).unwrap();
let port = url.port().unwrap_or(554);
let ip_address = match url.host() {
//For RTSP URLs, URL.host() does not return Host::Ipv4 or 6, it returns Domain
Some(Host::Domain(domain)) => format!("{}:{}", domain, port).parse().unwrap(),
None => panic!("missing host/url"),
_ => panic!(
"only IP hosts are accepted. Your host: {:?}",
url.host()
),
};
info!("Starting RTSP client for uri {}", uri_str);
let rtsp_client = Arc::new(Mutex::new(
Client::new(uri_str, None, None, rtsp_types::Version::V1_0).unwrap(),
));
Client::play(
rtsp_client,
ip_address,
Arc::new(|data: &Data<Body>| {
info!("<<< {} bytes", &data.len());
}),
)
.await.unwrap();
Ok(())
}Still gotta publish to crates.io