rafaelcaricio/gstreamer-rs
1
0
Fork 0
forked from mirrors/gstreamer-rs
Code Pull requests Activity

bus: add_watch() can fail as there can only be one watch at a time

Browse source 
Return an Option<SourceId> because of that.
This commit is contained in:
Sebastian Dröge 2019-02-15 13:30:05 +02:00
parent e24efa7259
commit a5a016557f
1 changed files with 18 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
gstreamer/src/bus.rs
View file

@ -111,35 +111,47 @@ impl Bus {
}
}
pub fn add_watch<F>(&self, func: F) -> SourceId
pub fn add_watch<F>(&self, func: F) -> Option<SourceId>
where
F: FnMut(&Bus, &Message) -> Continue + Send + 'static,
{
unsafe {
from_glib(ffi::gst_bus_add_watch_full(
let res = ffi::gst_bus_add_watch_full(
self.to_glib_none().0,
glib_ffi::G_PRIORITY_DEFAULT,
Some(trampoline_watch::<F>),
into_raw_watch(func),
Some(destroy_closure_watch::<F>),
))
);
if res == 0 {
None
} else {
Some(from_glib(res))
}
}
}
pub fn add_watch_local<F>(&self, func: F) -> SourceId
pub fn add_watch_local<F>(&self, func: F) -> Option<SourceId>
where
F: FnMut(&Bus, &Message) -> Continue + 'static,
{
unsafe {
assert!(glib::MainContext::ref_thread_default().is_owner());
from_glib(ffi::gst_bus_add_watch_full(
let res = ffi::gst_bus_add_watch_full(
self.to_glib_none().0,
glib_ffi::G_PRIORITY_DEFAULT,
Some(trampoline_watch::<F>),
into_raw_watch(func),
Some(destroy_closure_watch::<F>),
))
);
if res == 0 {
None
} else {
Some(from_glib(res))
}
}
}