Skip to content

lattice0/rrtsp_client

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

1 Commit
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

RRTSP Client

Currently works, but a lot of work to do. PRs welcome!

Example

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(())
}

Cargo.toml

Still gotta publish to crates.io

Releases

No releases published

Packages

No packages published

Languages