diff --git a/examples/src/bin/player.rs b/examples/src/bin/player.rs index c28113cfa..c6e8ac7ad 100644 --- a/examples/src/bin/player.rs +++ b/examples/src/bin/player.rs @@ -4,8 +4,6 @@ use gst::prelude::*; #[cfg(feature = "gst-player")] extern crate gstreamer_player as gst_player; -#[cfg(feature = "gst-player")] -use gst_player::prelude::*; extern crate glib; diff --git a/examples/src/bin/tokio.rs b/examples/src/bin/tokio.rs index 8f8dda92a..77293970b 100644 --- a/examples/src/bin/tokio.rs +++ b/examples/src/bin/tokio.rs @@ -28,7 +28,9 @@ fn main() { let ret = pipeline.set_state(gst::State::Playing); assert_ne!(ret, gst::StateChangeReturn::Failure); - let messages = BusStream::new(&bus).for_each(|msg| { + let messages = gst::BusStream::new(&bus).for_each(|msg| { + use gst::MessageView; + let quit = match msg.view() { MessageView::Eos(..) => true, MessageView::Error(err) => {