3 releases (breaking)
0.3.0 | Jul 1, 2019 |
---|---|
0.2.0 | Jan 8, 2019 |
0.1.0 | Jan 4, 2019 |
#401 in Video
29 downloads per month
Used in 2 crates
(via rsget_lib)
24KB
470 lines
Stream Lib
This library makes it possible to download various types of video streams. Currently it supports HLS and chunked http streams.
Example
use futures_util::StreamExt as _;
use reqwest::Client;
use stream_lib::Event;
use tokio::io::AsyncWriteExt;
/// Write buffer
pub const WRITE_SIZE: usize = 131_072;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
tracing_subscriber::fmt::init();
let args = std::env::args().collect::<Vec<_>>();
let url = args.get(1).expect("Pass a url as the first argument");
let http = Client::new();
let req = http.get(url).build()?;
let mut dl = stream_lib::download_hls(http, req, None);
let mut file = tokio::io::BufWriter::with_capacity(
WRITE_SIZE,
tokio::fs::File::create("./example.mp4").await?,
);
while let Some(event) = dl.next().await {
match event {
Event::Bytes { bytes } => {
file.write_all(&bytes).await?;
}
Event::End => break,
Event::Error { error } => {
eprintln!("Encounted error: {}", error);
break;
}
}
}
Ok(())
}
Dependencies
~19–29MB
~512K SLoC