1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
use glib;
use glib::IsA;
use glib::translate::ToGlibPtr;
use glib::signal::SignalHandlerId;
use glib::object::{Downcast, ObjectExt};
use gobject_ffi;
use std::ffi::CStr;
pub trait GstObjectExtManual {
fn connect_deep_notify<F: Fn(&Self, &::Object, &str) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
}
impl<O: IsA<::Object> + IsA<glib::Object> + glib::value::SetValue> GstObjectExtManual for O {
fn connect_deep_notify<F: Fn(&Self, &::Object, &str) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
self.connect("deep-notify", false, move |values| {
let obj: O = unsafe {
values[0]
.get::<glib::Object>()
.unwrap()
.downcast_unchecked()
};
let prop_obj: ::Object = values[1].get().unwrap();
let prop_name = unsafe {
let pspec = gobject_ffi::g_value_get_param(values[2].to_glib_none().0);
CStr::from_ptr((*pspec).name).to_str().unwrap()
};
f(&obj, &prop_obj, prop_name);
None
}).unwrap()
}
}
#[cfg(test)]
mod tests {
use super::*;
use prelude::*;
use std::sync::{Arc, Mutex};
#[test]
fn test_deep_notify() {
::init().unwrap();
let bin = ::Bin::new(None);
let identity = ::ElementFactory::make("identity", "id").unwrap();
bin.add(&identity).unwrap();
let notify = Arc::new(Mutex::new(None));
let notify_clone = notify.clone();
bin.connect_deep_notify(move |_, id, prop| {
*notify_clone.lock().unwrap() = Some((id.clone(), String::from(prop)));
});
identity.set_property("silent", &false).unwrap();
assert_eq!(
*notify.lock().unwrap(),
Some((identity.upcast::<::Object>(), String::from("silent")))
);
}
}