// This file was generated by gir (https://github.com/gtk-rs/gir) // from gir-files (https://github.com/gtk-rs/gir-files) // from gst-gir-files (https://gitlab.freedesktop.org/gstreamer/gir-files-rs.git) // DO NOT EDIT use crate::DiscovererInfo; use glib::{ prelude::*, signal::{connect_raw, SignalHandlerId}, translate::*, }; use std::{boxed::Box as Box_, mem::transmute, ptr}; glib::wrapper! { #[doc(alias = "GstDiscoverer")] pub struct Discoverer(Object); match fn { type_ => || ffi::gst_discoverer_get_type(), } } impl Discoverer { #[doc(alias = "gst_discoverer_new")] pub fn new(timeout: gst::ClockTime) -> Result { assert_initialized_main_thread!(); unsafe { let mut error = ptr::null_mut(); let ret = ffi::gst_discoverer_new(timeout.into_glib(), &mut error); if error.is_null() { Ok(from_glib_full(ret)) } else { Err(from_glib_full(error)) } } } #[doc(alias = "gst_discoverer_discover_uri")] pub fn discover_uri(&self, uri: &str) -> Result { unsafe { let mut error = ptr::null_mut(); let ret = ffi::gst_discoverer_discover_uri( self.to_glib_none().0, uri.to_glib_none().0, &mut error, ); if error.is_null() { Ok(from_glib_full(ret)) } else { Err(from_glib_full(error)) } } } #[doc(alias = "gst_discoverer_discover_uri_async")] pub fn discover_uri_async(&self, uri: &str) -> Result<(), glib::error::BoolError> { unsafe { glib::result_from_gboolean!( ffi::gst_discoverer_discover_uri_async(self.to_glib_none().0, uri.to_glib_none().0), "Failed to add URI to list of discovers" ) } } #[doc(alias = "gst_discoverer_start")] pub fn start(&self) { unsafe { ffi::gst_discoverer_start(self.to_glib_none().0); } } #[doc(alias = "gst_discoverer_stop")] pub fn stop(&self) { unsafe { ffi::gst_discoverer_stop(self.to_glib_none().0); } } #[cfg(feature = "v1_16")] #[cfg_attr(docsrs, doc(cfg(feature = "v1_16")))] #[doc(alias = "use-cache")] pub fn uses_cache(&self) -> bool { ObjectExt::property(self, "use-cache") } #[cfg(feature = "v1_16")] #[cfg_attr(docsrs, doc(cfg(feature = "v1_16")))] #[doc(alias = "use-cache")] pub fn set_use_cache(&self, use_cache: bool) { ObjectExt::set_property(self, "use-cache", use_cache) } #[doc(alias = "discovered")] pub fn connect_discovered< F: Fn(&Self, &DiscovererInfo, Option<&glib::Error>) + Send + Sync + 'static, >( &self, f: F, ) -> SignalHandlerId { unsafe extern "C" fn discovered_trampoline< F: Fn(&Discoverer, &DiscovererInfo, Option<&glib::Error>) + Send + Sync + 'static, >( this: *mut ffi::GstDiscoverer, info: *mut ffi::GstDiscovererInfo, error: *mut glib::ffi::GError, f: glib::ffi::gpointer, ) { let f: &F = &*(f as *const F); f( &from_glib_borrow(this), &from_glib_borrow(info), Option::::from_glib_borrow(error) .as_ref() .as_ref(), ) } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"discovered\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( discovered_trampoline:: as *const (), )), Box_::into_raw(f), ) } } #[doc(alias = "finished")] pub fn connect_finished(&self, f: F) -> SignalHandlerId { unsafe extern "C" fn finished_trampoline( this: *mut ffi::GstDiscoverer, f: glib::ffi::gpointer, ) { let f: &F = &*(f as *const F); f(&from_glib_borrow(this)) } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"finished\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( finished_trampoline:: as *const (), )), Box_::into_raw(f), ) } } #[cfg(feature = "v1_24")] #[cfg_attr(docsrs, doc(cfg(feature = "v1_24")))] #[doc(alias = "load-serialized-info")] pub fn connect_load_serialized_info< F: Fn(&Self, &str) -> Option + Send + Sync + 'static, >( &self, f: F, ) -> SignalHandlerId { unsafe extern "C" fn load_serialized_info_trampoline< F: Fn(&Discoverer, &str) -> Option + Send + Sync + 'static, >( this: *mut ffi::GstDiscoverer, uri: *mut libc::c_char, f: glib::ffi::gpointer, ) -> *mut ffi::GstDiscovererInfo { let f: &F = &*(f as *const F); f( &from_glib_borrow(this), &glib::GString::from_glib_borrow(uri), ) .to_glib_full() } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"load-serialized-info\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( load_serialized_info_trampoline:: as *const (), )), Box_::into_raw(f), ) } } #[doc(alias = "source-setup")] pub fn connect_source_setup( &self, f: F, ) -> SignalHandlerId { unsafe extern "C" fn source_setup_trampoline< F: Fn(&Discoverer, &gst::Element) + Send + Sync + 'static, >( this: *mut ffi::GstDiscoverer, source: *mut gst::ffi::GstElement, f: glib::ffi::gpointer, ) { let f: &F = &*(f as *const F); f(&from_glib_borrow(this), &from_glib_borrow(source)) } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"source-setup\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( source_setup_trampoline:: as *const (), )), Box_::into_raw(f), ) } } #[doc(alias = "starting")] pub fn connect_starting(&self, f: F) -> SignalHandlerId { unsafe extern "C" fn starting_trampoline( this: *mut ffi::GstDiscoverer, f: glib::ffi::gpointer, ) { let f: &F = &*(f as *const F); f(&from_glib_borrow(this)) } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"starting\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( starting_trampoline:: as *const (), )), Box_::into_raw(f), ) } } #[cfg(feature = "v1_16")] #[cfg_attr(docsrs, doc(cfg(feature = "v1_16")))] #[doc(alias = "use-cache")] pub fn connect_use_cache_notify( &self, f: F, ) -> SignalHandlerId { unsafe extern "C" fn notify_use_cache_trampoline< F: Fn(&Discoverer) + Send + Sync + 'static, >( this: *mut ffi::GstDiscoverer, _param_spec: glib::ffi::gpointer, f: glib::ffi::gpointer, ) { let f: &F = &*(f as *const F); f(&from_glib_borrow(this)) } unsafe { let f: Box_ = Box_::new(f); connect_raw( self.as_ptr() as *mut _, b"notify::use-cache\0".as_ptr() as *const _, Some(transmute::<_, unsafe extern "C" fn()>( notify_use_cache_trampoline:: as *const (), )), Box_::into_raw(f), ) } } } unsafe impl Send for Discoverer {} unsafe impl Sync for Discoverer {}