2017-09-01 10:42:59 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
extern crate gstreamer as gst;
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-08-17 14:58:15 +00:00
|
|
|
use gst::prelude::*;
|
2017-07-31 13:12:08 +00:00
|
|
|
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
extern crate futures;
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
use futures::stream::Stream;
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
extern crate tokio_core;
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
use tokio_core::reactor::Core;
|
|
|
|
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
use std::env;
|
|
|
|
|
2017-08-17 10:07:32 +00:00
|
|
|
#[cfg(feature = "tokio")]
|
2017-07-31 13:12:08 +00:00
|
|
|
fn main() {
|
|
|
|
let pipeline_str = env::args().collect::<Vec<String>>()[1..].join(" ");
|
|
|
|
|
|
|
|
gst::init().unwrap();
|
|
|
|
|
|
|
|
let mut core = Core::new().unwrap();
|
|
|
|
|
|
|
|
let pipeline = gst::parse_launch(&pipeline_str).unwrap();
|
|
|
|
let bus = pipeline.get_bus().unwrap();
|
|
|
|
|
|
|
|
let ret = pipeline.set_state(gst::State::Playing);
|
|
|
|
assert_ne!(ret, gst::StateChangeReturn::Failure);
|
|
|
|
|
2017-08-17 15:16:48 +00:00
|
|
|
let messages = gst::BusStream::new(&bus).for_each(|msg| {
|
|
|
|
use gst::MessageView;
|
|
|
|
|
2017-07-31 13:12:08 +00:00
|
|
|
let quit = match msg.view() {
|
|
|
|
MessageView::Eos(..) => true,
|
|
|
|
MessageView::Error(err) => {
|
|
|
|
println!(
|
|
|
|
"Error from {}: {} ({:?})",
|
|
|
|
msg.get_src().get_path_string(),
|
|
|
|
err.get_error(),
|
|
|
|
err.get_debug()
|
|
|
|
);
|
|
|
|
true
|
|
|
|
}
|
|
|
|
_ => false,
|
|
|
|
};
|
|
|
|
|
|
|
|
if quit {
|
|
|
|
Err(())
|
|
|
|
} else {
|
|
|
|
Ok(())
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
let _ = core.run(messages);
|
|
|
|
|
|
|
|
let ret = pipeline.set_state(gst::State::Null);
|
|
|
|
assert_ne!(ret, gst::StateChangeReturn::Failure);
|
|
|
|
}
|
2017-08-17 10:07:32 +00:00
|
|
|
|
|
|
|
#[cfg(not(feature = "tokio"))]
|
|
|
|
fn main() {
|
|
|
|
println!("Please compile with --features tokio");
|
|
|
|
}
|