gstreamer-rs/gstreamer/src/object.rs

74 lines
2.2 KiB
Rust
Raw Normal View History

// Copyright (C) 2017 Sebastian Dröge <sebastian@centricular.com>
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.
use glib;
use glib::{Cast, IsA};
use glib::translate::ToGlibPtr;
use glib::signal::SignalHandlerId;
use glib::object::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 = values[0].get::<glib::Object>().unwrap().downcast().unwrap();
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")))
);
}
}