[−][src]Struct gstreamer_app::AppSrc
The appsrc element can be used by applications to insert data into a GStreamer pipeline. Unlike most GStreamer elements, appsrc provides external API functions.
appsrc can be used by linking with the libgstapp library to access the methods directly or by using the appsrc action signals.
Before operating appsrc, the caps property must be set to fixed caps describing the format of the data that will be pushed with appsrc. An exception to this is when pushing buffers with unknown caps, in which case no caps should be set. This is typically true of file-like sources that push raw byte buffers. If you don't want to explicitly set the caps, you can use gst_app_src_push_sample. This method gets the caps associated with the sample and sets them on the appsrc replacing any previously set caps (if different from sample's caps).
The main way of handing data to the appsrc element is by calling the
AppSrc::push_buffer method or by emitting the push-buffer action signal.
This will put the buffer onto a queue from which appsrc will read from in its
streaming thread. It is important to note that data transport will not happen
from the thread that performed the push-buffer call.
The "max-bytes" property controls how much data can be queued in appsrc before appsrc considers the queue full. A filled internal queue will always signal the "enough-data" signal, which signals the application that it should stop pushing data into appsrc. The "block" property will cause appsrc to block the push-buffer method until free data becomes available again.
When the internal queue is running out of data, the "need-data" signal is emitted, which signals the application that it should start pushing more data into appsrc.
In addition to the "need-data" and "enough-data" signals, appsrc can emit the "seek-data" signal when the "stream-mode" property is set to "seekable" or "random-access". The signal argument will contain the new desired position in the stream expressed in the unit set with the "format" property. After receiving the seek-data signal, the application should push-buffers from the new position.
These signals allow the application to operate the appsrc in two different ways:
The push mode, in which the application repeatedly calls the push-buffer/push-sample method with a new buffer/sample. Optionally, the queue size in the appsrc can be controlled with the enough-data and need-data signals by respectively stopping/starting the push-buffer/push-sample calls. This is a typical mode of operation for the stream-type "stream" and "seekable". Use this mode when implementing various network protocols or hardware devices.
The pull mode, in which the need-data signal triggers the next push-buffer call. This mode is typically used in the "random-access" stream-type. Use this mode for file access or other randomly accessible sources. In this mode, a buffer of exactly the amount of bytes given by the need-data signal should be pushed into appsrc.
In all modes, the size property on appsrc should contain the total stream size in bytes. Setting this property is mandatory in the random-access mode. For the stream and seekable modes, setting this property is optional but recommended.
When the application has finished pushing data into appsrc, it should call
AppSrc::end_of_stream or emit the end-of-stream action signal. After
this call, no more buffers can be pushed into appsrc until a flushing seek
occurs or the state of the appsrc has gone through READY.
Implements
gst_base::BaseSrcExt, gst::ElementExt, gst::ObjectExt, glib::object::ObjectExt, gst::URIHandlerExt
Implementations
impl AppSrc[src]
pub fn get_caps(&self) -> Option<Caps>[src]
Get the configured caps on self.
Returns
the gst::Caps produced by the source. gst::Caps::unref after usage.
pub fn get_current_level_bytes(&self) -> u64[src]
pub fn get_duration(&self) -> ClockTime[src]
Get the duration of the stream in nanoseconds. A value of GST_CLOCK_TIME_NONE means that the duration is not known.
Feature: v1_10
Returns
the duration of the stream previously set with AppSrc::set_duration;
pub fn get_emit_signals(&self) -> bool[src]
Check if appsrc will emit the "new-preroll" and "new-buffer" signals.
Returns
true if self is emitting the "new-preroll" and "new-buffer"
signals.
pub fn get_max_bytes(&self) -> u64[src]
Get the maximum amount of bytes that can be queued in self.
Returns
The maximum amount of bytes that can be queued.
pub fn get_size(&self) -> i64[src]
Get the size of the stream in bytes. A value of -1 means that the size is not known.
Returns
the size of the stream previously set with AppSrc::set_size;
pub fn get_stream_type(&self) -> AppStreamType[src]
Get the stream type. Control the stream type of self
with AppSrc::set_stream_type.
Returns
the stream type.
pub fn set_caps(&self, caps: Option<&Caps>)[src]
Set the capabilities on the appsrc element. This function takes
a copy of the caps structure. After calling this method, the source will
only produce caps that match caps. caps must be fixed and the caps on the
buffers must match the caps or left NULL.
caps
caps to set
pub fn set_duration(&self, duration: ClockTime)[src]
Set the duration of the stream in nanoseconds. A value of GST_CLOCK_TIME_NONE means that the duration is not known.
Feature: v1_10
duration
the duration to set
pub fn set_emit_signals(&self, emit: bool)[src]
Make appsrc emit the "new-preroll" and "new-buffer" signals. This option is by default disabled because signal emission is expensive and unneeded when the application prefers to operate in pull mode.
emit
the new state
pub fn set_max_bytes(&self, max: u64)[src]
Set the maximum amount of bytes that can be queued in self.
After the maximum amount of bytes are queued, self will emit the
"enough-data" signal.
max
the maximum number of bytes to queue
pub fn set_size(&self, size: i64)[src]
Set the size of the stream in bytes. A value of -1 means that the size is not known.
size
the size to set
pub fn set_stream_type(&self, type_: AppStreamType)[src]
Set the stream type on self. For seekable streams, the "seek" signal must
be connected to.
A stream_type stream
type_
the new state
pub fn get_property_block(&self) -> bool[src]
pub fn set_property_block(&self, block: bool)[src]
pub fn get_property_format(&self) -> Format[src]
pub fn set_property_format(&self, format: Format)[src]
pub fn get_property_handle_segment_change(&self) -> bool[src]
pub fn set_property_handle_segment_change(&self, handle_segment_change: bool)[src]
pub fn get_property_is_live(&self) -> bool[src]
pub fn set_property_is_live(&self, is_live: bool)[src]
pub fn get_property_max_latency(&self) -> i64[src]
pub fn set_property_max_latency(&self, max_latency: i64)[src]
pub fn get_property_min_latency(&self) -> i64[src]
pub fn set_property_min_latency(&self, min_latency: i64)[src]
pub fn get_property_min_percent(&self) -> u32[src]
pub fn set_property_min_percent(&self, min_percent: u32)[src]
pub fn connect_enough_data<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
Signal that the source has enough data. It is recommended that the application stops calling push-buffer until the need-data signal is emitted again to avoid excessive buffer queueing.
pub fn connect_need_data<F: Fn(&AppSrc, u32) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
Signal that the source needs more data. In the callback or from another thread you should call push-buffer or end-of-stream.
length is just a hint and when it is set to -1, any number of bytes can be
pushed into appsrc.
You can call push-buffer multiple times until the enough-data signal is fired.
length
the amount of bytes needed.
pub fn connect_seek_data<F: Fn(&AppSrc, u64) -> bool + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
Seek to the given offset. The next push-buffer should produce buffers from
the new offset.
This callback is only called for seekable stream types.
offset
the offset to seek to
Returns
true if the seek succeeded.
pub fn connect_property_block_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_caps_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_current_level_bytes_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_duration_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_emit_signals_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_format_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_handle_segment_change_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_is_live_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_max_bytes_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_max_latency_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_min_latency_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_min_percent_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_size_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
pub fn connect_property_stream_type_notify<F: Fn(&AppSrc) + Send + Sync + 'static>(
&self,
f: F
) -> SignalHandlerId[src]
&self,
f: F
) -> SignalHandlerId
impl AppSrc[src]
pub fn end_of_stream(&self) -> Result<FlowSuccess, FlowError>[src]
Indicates to the appsrc element that the last buffer queued in the element is the last buffer of the stream.
Returns
gst::FlowReturn::Ok when the EOS was successfully queued.
gst::FlowReturn::Flushing when self is not PAUSED or PLAYING.
pub fn push_buffer(&self, buffer: Buffer) -> Result<FlowSuccess, FlowError>[src]
Adds a buffer to the queue of buffers that the appsrc element will push to its source pad. This function takes ownership of the buffer.
When the block property is TRUE, this function can block until free space becomes available in the queue.
buffer
a gst::Buffer to push
Returns
gst::FlowReturn::Ok when the buffer was successfully queued.
gst::FlowReturn::Flushing when self is not PAUSED or PLAYING.
gst::FlowReturn::Eos when EOS occurred.
pub fn push_buffer_list(
&self,
list: BufferList
) -> Result<FlowSuccess, FlowError>[src]
&self,
list: BufferList
) -> Result<FlowSuccess, FlowError>
Adds a buffer list to the queue of buffers and buffer lists that the
appsrc element will push to its source pad. This function takes ownership
of buffer_list.
When the block property is TRUE, this function can block until free space becomes available in the queue.
Feature: v1_14
buffer_list
a gst::BufferList to push
Returns
gst::FlowReturn::Ok when the buffer list was successfully queued.
gst::FlowReturn::Flushing when self is not PAUSED or PLAYING.
gst::FlowReturn::Eos when EOS occurred.
pub fn push_sample(&self, sample: &Sample) -> Result<FlowSuccess, FlowError>[src]
Extract a buffer from the provided sample and adds it to the queue of buffers that the appsrc element will push to its source pad. Any previous caps that were set on appsrc will be replaced by the caps associated with the sample if not equal.
This function does not take ownership of the sample so the sample needs to be unreffed after calling this function.
When the block property is TRUE, this function can block until free space becomes available in the queue.
sample
a gst::Sample from which buffer and caps may be
extracted
Returns
gst::FlowReturn::Ok when the buffer was successfully queued.
gst::FlowReturn::Flushing when self is not PAUSED or PLAYING.
gst::FlowReturn::Eos when EOS occurred.
pub fn set_callbacks(&self, callbacks: AppSrcCallbacks)[src]
Set callbacks which will be executed when data is needed, enough data has been collected or when a seek should be performed. This is an alternative to using the signals, it has lower overhead and is thus less expensive, but also less flexible.
If callbacks are installed, no signals will be emitted for performance reasons.
Before 1.16.3 it was not possible to change the callbacks in a thread-safe way.
callbacks
the callbacks
user_data
a user_data argument for the callbacks
notify
a destroy notify function
pub fn set_latency(&self, min: ClockTime, max: ClockTime)[src]
Configure the min and max latency in src. If min is set to -1, the
default latency calculations for pseudo-live sources will be used.
min
the min latency
max
the max latency
pub fn get_latency(&self) -> (ClockTime, ClockTime)[src]
Retrieve the min and max latencies in min and max respectively.
min
the min latency
max
the max latency
pub fn sink(&self) -> AppSrcSink[src]
Trait Implementations
impl Clone for AppSrc[src]
impl Debug for AppSrc[src]
impl Eq for AppSrc[src]
impl Hash for AppSrc[src]
fn hash<__H: Hasher>(&self, state: &mut __H)[src]
fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher, 1.3.0[src]
H: Hasher,
impl IsA<BaseSrc> for AppSrc[src]
impl IsA<Element> for AppSrc[src]
impl IsA<Object> for AppSrc[src]
impl IsA<URIHandler> for AppSrc[src]
impl Ord for AppSrc[src]
fn cmp(&self, other: &AppSrc) -> Ordering[src]
#[must_use]fn max(self, other: Self) -> Self1.21.0[src]
#[must_use]fn min(self, other: Self) -> Self1.21.0[src]
#[must_use]fn clamp(self, min: Self, max: Self) -> Self[src]
impl<T: ObjectType> PartialEq<T> for AppSrc[src]
impl<T: ObjectType> PartialOrd<T> for AppSrc[src]
fn partial_cmp(&self, other: &T) -> Option<Ordering>[src]
#[must_use]fn lt(&self, other: &Rhs) -> bool1.0.0[src]
#[must_use]fn le(&self, other: &Rhs) -> bool1.0.0[src]
#[must_use]fn gt(&self, other: &Rhs) -> bool1.0.0[src]
#[must_use]fn ge(&self, other: &Rhs) -> bool1.0.0[src]
impl Send for AppSrc[src]
impl StaticType for AppSrc[src]
fn static_type() -> Type[src]
impl Sync for AppSrc[src]
Auto Trait Implementations
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<O> BaseSrcExt for O where
O: IsA<BaseSrc>,
O: IsA<BaseSrc>,
fn get_blocksize(&self) -> u32
fn get_buffer_pool(&self) -> Option<BufferPool>
fn get_do_timestamp(&self) -> bool
fn is_async(&self) -> bool
fn is_live(&self) -> bool
fn negotiate(&self) -> bool
fn new_seamless_segment(&self, start: i64, stop: i64, time: i64) -> bool
fn set_async(&self, async: bool)
fn set_automatic_eos(&self, automatic_eos: bool)
fn set_blocksize(&self, blocksize: u32)
fn set_caps(&self, caps: &Caps) -> Result<(), BoolError>
fn set_do_timestamp(&self, timestamp: bool)
fn set_dynamic_size(&self, dynamic: bool)
fn set_format(&self, format: Format)
fn set_live(&self, live: bool)
fn get_property_num_buffers(&self) -> i32
fn set_property_num_buffers(&self, num_buffers: i32)
fn get_property_typefind(&self) -> bool
fn set_property_typefind(&self, typefind: bool)
fn connect_property_blocksize_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O),
F: 'static + Send + Sync + Fn(&O),
fn connect_property_do_timestamp_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O),
F: 'static + Send + Sync + Fn(&O),
fn connect_property_num_buffers_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O),
F: 'static + Send + Sync + Fn(&O),
fn connect_property_typefind_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O),
F: 'static + Send + Sync + Fn(&O),
impl<O> BaseSrcExtManual for O where
O: IsA<BaseSrc>,
O: IsA<BaseSrc>,
fn get_allocator(&self) -> (Option<Allocator>, AllocationParams)
fn get_segment(&self) -> FormattedSegment<GenericFormattedValue>
fn start_complete(&self, ret: Result<FlowSuccess, FlowError>)
fn start_wait(&self) -> Result<FlowSuccess, FlowError>
fn wait_playing(&self) -> Result<FlowSuccess, FlowError>
fn query_latency(&self) -> Result<(bool, ClockTime, ClockTime), BoolError>
fn new_segment(
&self,
segment: &FormattedSegment<GenericFormattedValue>
) -> Result<(), BoolError>
&self,
segment: &FormattedSegment<GenericFormattedValue>
) -> Result<(), BoolError>
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<Super, Sub> CanDowncast<Sub> for Super where
Sub: IsA<Super>,
Super: IsA<Super>, [src]
Sub: IsA<Super>,
Super: IsA<Super>,
impl<T> Cast for T where
T: ObjectType, [src]
T: ObjectType,
fn upcast<T>(self) -> T where
Self: IsA<T>,
T: ObjectType, [src]
Self: IsA<T>,
T: ObjectType,
fn upcast_ref<T>(&self) -> &T where
Self: IsA<T>,
T: ObjectType, [src]
Self: IsA<T>,
T: ObjectType,
fn downcast<T>(self) -> Result<T, Self> where
Self: CanDowncast<T>,
T: ObjectType, [src]
Self: CanDowncast<T>,
T: ObjectType,
fn downcast_ref<T>(&self) -> Option<&T> where
Self: CanDowncast<T>,
T: ObjectType, [src]
Self: CanDowncast<T>,
T: ObjectType,
fn dynamic_cast<T>(self) -> Result<T, Self> where
T: ObjectType, [src]
T: ObjectType,
fn dynamic_cast_ref<T>(&self) -> Option<&T> where
T: ObjectType, [src]
T: ObjectType,
unsafe fn unsafe_cast<T>(self) -> T where
T: ObjectType, [src]
T: ObjectType,
unsafe fn unsafe_cast_ref<T>(&self) -> &T where
T: ObjectType, [src]
T: ObjectType,
impl<O> ElementExt for O where
O: IsA<Element>, [src]
O: IsA<Element>,
fn abort_state(&self)[src]
fn add_pad<P>(&self, pad: &P) -> Result<(), BoolError> where
P: IsA<Pad>, [src]
P: IsA<Pad>,
fn create_all_pads(&self)[src]
fn foreach_pad<P>(&self, func: P) -> bool where
P: FnMut(&Element, &Pad) -> bool, [src]
P: FnMut(&Element, &Pad) -> bool,
fn foreach_sink_pad<P>(&self, func: P) -> bool where
P: FnMut(&Element, &Pad) -> bool, [src]
P: FnMut(&Element, &Pad) -> bool,
fn foreach_src_pad<P>(&self, func: P) -> bool where
P: FnMut(&Element, &Pad) -> bool, [src]
P: FnMut(&Element, &Pad) -> bool,
fn get_base_time(&self) -> ClockTime[src]
fn get_bus(&self) -> Option<Bus>[src]
fn get_clock(&self) -> Option<Clock>[src]
fn get_compatible_pad<P>(&self, pad: &P, caps: Option<&Caps>) -> Option<Pad> where
P: IsA<Pad>, [src]
P: IsA<Pad>,
fn get_compatible_pad_template(
&self,
compattempl: &PadTemplate
) -> Option<PadTemplate>[src]
&self,
compattempl: &PadTemplate
) -> Option<PadTemplate>
fn get_context(&self, context_type: &str) -> Option<Context>[src]
fn get_contexts(&self) -> Vec<Context>[src]
fn get_factory(&self) -> Option<ElementFactory>[src]
fn get_request_pad(&self, name: &str) -> Option<Pad>[src]
fn get_start_time(&self) -> ClockTime[src]
fn get_static_pad(&self, name: &str) -> Option<Pad>[src]
fn is_locked_state(&self) -> bool[src]
fn link<P>(&self, dest: &P) -> Result<(), BoolError> where
P: IsA<Element>, [src]
P: IsA<Element>,
fn link_filtered<P>(
&self,
dest: &P,
filter: Option<&Caps>
) -> Result<(), BoolError> where
P: IsA<Element>, [src]
&self,
dest: &P,
filter: Option<&Caps>
) -> Result<(), BoolError> where
P: IsA<Element>,
fn link_pads<P>(
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>
) -> Result<(), BoolError> where
P: IsA<Element>, [src]
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>
) -> Result<(), BoolError> where
P: IsA<Element>,
fn link_pads_filtered<P>(
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>,
filter: Option<&Caps>
) -> Result<(), BoolError> where
P: IsA<Element>, [src]
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>,
filter: Option<&Caps>
) -> Result<(), BoolError> where
P: IsA<Element>,
fn link_pads_full<P>(
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>,
flags: PadLinkCheck
) -> Result<(), BoolError> where
P: IsA<Element>, [src]
&self,
srcpadname: Option<&str>,
dest: &P,
destpadname: Option<&str>,
flags: PadLinkCheck
) -> Result<(), BoolError> where
P: IsA<Element>,
fn lost_state(&self)[src]
fn no_more_pads(&self)[src]
fn provide_clock(&self) -> Option<Clock>[src]
fn release_request_pad<P>(&self, pad: &P) where
P: IsA<Pad>, [src]
P: IsA<Pad>,
fn remove_pad<P>(&self, pad: &P) -> Result<(), BoolError> where
P: IsA<Pad>, [src]
P: IsA<Pad>,
fn request_pad(
&self,
templ: &PadTemplate,
name: Option<&str>,
caps: Option<&Caps>
) -> Option<Pad>[src]
&self,
templ: &PadTemplate,
name: Option<&str>,
caps: Option<&Caps>
) -> Option<Pad>
fn set_base_time(&self, time: ClockTime)[src]
fn set_bus(&self, bus: Option<&Bus>)[src]
fn set_clock<P>(&self, clock: Option<&P>) -> Result<(), BoolError> where
P: IsA<Clock>, [src]
P: IsA<Clock>,
fn set_context(&self, context: &Context)[src]
fn set_locked_state(&self, locked_state: bool) -> bool[src]
fn set_start_time(&self, time: ClockTime)[src]
fn sync_state_with_parent(&self) -> Result<(), BoolError>[src]
fn unlink<P>(&self, dest: &P) where
P: IsA<Element>, [src]
P: IsA<Element>,
fn unlink_pads<P>(&self, srcpadname: &str, dest: &P, destpadname: &str) where
P: IsA<Element>, [src]
P: IsA<Element>,
fn connect_no_more_pads<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O), [src]
F: 'static + Send + Sync + Fn(&O),
fn connect_pad_added<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O, &Pad), [src]
F: 'static + Send + Sync + Fn(&O, &Pad),
fn connect_pad_removed<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O, &Pad), [src]
F: 'static + Send + Sync + Fn(&O, &Pad),
impl<O> ElementExtManual for O where
O: IsA<Element>, [src]
O: IsA<Element>,
fn get_element_class(&self) -> &ElementClass[src]
fn change_state(
&self,
transition: StateChange
) -> Result<StateChangeSuccess, StateChangeError>[src]
&self,
transition: StateChange
) -> Result<StateChangeSuccess, StateChangeError>
fn continue_state(
&self,
ret: StateChangeReturn
) -> Result<StateChangeSuccess, StateChangeError>[src]
&self,
ret: StateChangeReturn
) -> Result<StateChangeSuccess, StateChangeError>
fn get_state(
&self,
timeout: ClockTime
) -> (Result<StateChangeSuccess, StateChangeError>, State, State)[src]
&self,
timeout: ClockTime
) -> (Result<StateChangeSuccess, StateChangeError>, State, State)
fn set_state(
&self,
state: State
) -> Result<StateChangeSuccess, StateChangeError>[src]
&self,
state: State
) -> Result<StateChangeSuccess, StateChangeError>
fn query(&self, query: &mut QueryRef) -> bool[src]
fn send_event(&self, event: Event) -> bool[src]
fn get_metadata<'a>(&self, key: &str) -> Option<&'a str>[src]
fn get_pad_template(&self, name: &str) -> Option<PadTemplate>[src]
fn get_pad_template_list(&self) -> Vec<PadTemplate>[src]
fn set_element_flags(&self, flags: ElementFlags)[src]
fn unset_element_flags(&self, flags: ElementFlags)[src]
fn get_element_flags(&self) -> ElementFlags[src]
fn message_full<T>(
&self,
type_: ElementMessageType,
code: T,
message: Option<&str>,
debug: Option<&str>,
file: &str,
function: &str,
line: u32
) where
T: MessageErrorDomain, [src]
&self,
type_: ElementMessageType,
code: T,
message: Option<&str>,
debug: Option<&str>,
file: &str,
function: &str,
line: u32
) where
T: MessageErrorDomain,
fn message_full_with_details<T>(
&self,
type_: ElementMessageType,
code: T,
message: Option<&str>,
debug: Option<&str>,
file: &str,
function: &str,
line: u32,
structure: Structure
) where
T: MessageErrorDomain, [src]
&self,
type_: ElementMessageType,
code: T,
message: Option<&str>,
debug: Option<&str>,
file: &str,
function: &str,
line: u32,
structure: Structure
) where
T: MessageErrorDomain,
fn post_message(&self, message: Message) -> Result<(), BoolError>[src]
fn post_error_message(&self, msg: ErrorMessage)[src]
fn iterate_pads(&self) -> Iterator<Pad>[src]
fn iterate_sink_pads(&self) -> Iterator<Pad>[src]
fn iterate_src_pads(&self) -> Iterator<Pad>[src]
fn get_pads(&self) -> Vec<Pad>[src]
fn get_sink_pads(&self) -> Vec<Pad>[src]
fn get_src_pads(&self) -> Vec<Pad>[src]
fn num_pads(&self) -> u16[src]
fn num_sink_pads(&self) -> u16[src]
fn num_src_pads(&self) -> u16[src]
fn add_property_deep_notify_watch(
&self,
property_name: Option<&str>,
include_value: bool
) -> NotifyWatchId[src]
&self,
property_name: Option<&str>,
include_value: bool
) -> NotifyWatchId
fn add_property_notify_watch(
&self,
property_name: Option<&str>,
include_value: bool
) -> NotifyWatchId[src]
&self,
property_name: Option<&str>,
include_value: bool
) -> NotifyWatchId
fn remove_property_notify_watch(&self, watch_id: NotifyWatchId)[src]
fn query_convert<V, U>(&self, src_val: V) -> Option<U> where
U: SpecificFormattedValue,
V: Into<GenericFormattedValue>, [src]
U: SpecificFormattedValue,
V: Into<GenericFormattedValue>,
fn query_convert_generic<V>(
&self,
src_val: V,
dest_format: Format
) -> Option<GenericFormattedValue> where
V: Into<GenericFormattedValue>, [src]
&self,
src_val: V,
dest_format: Format
) -> Option<GenericFormattedValue> where
V: Into<GenericFormattedValue>,
fn query_duration<T>(&self) -> Option<T> where
T: SpecificFormattedValue, [src]
T: SpecificFormattedValue,
fn query_duration_generic(
&self,
format: Format
) -> Option<GenericFormattedValue>[src]
&self,
format: Format
) -> Option<GenericFormattedValue>
fn query_position<T>(&self) -> Option<T> where
T: SpecificFormattedValue, [src]
T: SpecificFormattedValue,
fn query_position_generic(
&self,
format: Format
) -> Option<GenericFormattedValue>[src]
&self,
format: Format
) -> Option<GenericFormattedValue>
fn seek<V>(
&self,
rate: f64,
flags: SeekFlags,
start_type: SeekType,
start: V,
stop_type: SeekType,
stop: V
) -> Result<(), BoolError> where
V: Into<GenericFormattedValue>, [src]
&self,
rate: f64,
flags: SeekFlags,
start_type: SeekType,
start: V,
stop_type: SeekType,
stop: V
) -> Result<(), BoolError> where
V: Into<GenericFormattedValue>,
fn seek_simple<V>(
&self,
seek_flags: SeekFlags,
seek_pos: V
) -> Result<(), BoolError> where
V: Into<GenericFormattedValue>, [src]
&self,
seek_flags: SeekFlags,
seek_pos: V
) -> Result<(), BoolError> where
V: Into<GenericFormattedValue>,
fn call_async<F>(&self, func: F) where
F: FnOnce(&O) + Send + 'static, [src]
F: FnOnce(&O) + Send + 'static,
fn call_async_future<F, T>(
&self,
func: F
) -> Pin<Box<dyn Future<Output = T> + 'static + Send + Unpin>> where
F: FnOnce(&O) -> T + Send + 'static,
T: Send + 'static, [src]
&self,
func: F
) -> Pin<Box<dyn Future<Output = T> + 'static + Send + Unpin>> where
F: FnOnce(&O) -> T + Send + 'static,
T: Send + 'static,
fn get_current_running_time(&self) -> ClockTime[src]
fn get_current_clock_time(&self) -> ClockTime[src]
fn get_current_state(&self) -> State[src]
fn get_pending_state(&self) -> State[src]
impl<T> From<T> for T[src]
impl<O> GObjectExtManualGst for O where
O: IsA<Object>, [src]
O: IsA<Object>,
fn set_property_from_str(&self, name: &str, value: &str)[src]
impl<O> GstObjectExt for O where
O: IsA<Object>, [src]
O: IsA<Object>,
fn default_error(&self, error: &Error, debug: Option<&str>)[src]
fn get_control_rate(&self) -> ClockTime[src]
fn get_name(&self) -> GString[src]
fn get_parent(&self) -> Option<Object>[src]
fn get_path_string(&self) -> GString[src]
fn has_active_control_bindings(&self) -> bool[src]
fn has_ancestor<P>(&self, ancestor: &P) -> bool where
P: IsA<Object>, [src]
P: IsA<Object>,
fn has_as_ancestor<P>(&self, ancestor: &P) -> bool where
P: IsA<Object>, [src]
P: IsA<Object>,
fn has_as_parent<P>(&self, parent: &P) -> bool where
P: IsA<Object>, [src]
P: IsA<Object>,
fn set_control_binding_disabled(&self, property_name: &str, disabled: bool)[src]
fn set_control_bindings_disabled(&self, disabled: bool)[src]
fn set_control_rate(&self, control_rate: ClockTime)[src]
fn set_parent<P>(&self, parent: &P) -> Result<(), BoolError> where
P: IsA<Object>, [src]
P: IsA<Object>,
fn suggest_next_sync(&self) -> ClockTime[src]
fn sync_values(&self, timestamp: ClockTime) -> Result<(), BoolError>[src]
fn unparent(&self)[src]
fn connect_property_parent_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O), [src]
F: 'static + Send + Sync + Fn(&O),
impl<O> GstObjectExtManual for O where
O: IsA<Object>, [src]
O: IsA<Object>,
fn connect_deep_notify<F>(&self, name: Option<&str>, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&O, &Object, &ParamSpec), [src]
F: 'static + Send + Sync + Fn(&O, &Object, &ParamSpec),
fn set_object_flags(&self, flags: ObjectFlags)[src]
fn unset_object_flags(&self, flags: ObjectFlags)[src]
fn get_object_flags(&self) -> ObjectFlags[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> ObjectExt for T where
T: ObjectType, [src]
T: ObjectType,
fn is<U>(&self) -> bool where
U: StaticType, [src]
U: StaticType,
fn get_type(&self) -> Type[src]
fn get_object_class(&self) -> &ObjectClass[src]
fn set_properties(
&self,
property_values: &[(&str, &dyn ToValue)]
) -> Result<(), BoolError>[src]
&self,
property_values: &[(&str, &dyn ToValue)]
) -> Result<(), BoolError>
fn set_property<'a, N>(
&self,
property_name: N,
value: &dyn ToValue
) -> Result<(), BoolError> where
N: Into<&'a str>, [src]
&self,
property_name: N,
value: &dyn ToValue
) -> Result<(), BoolError> where
N: Into<&'a str>,
fn get_property<'a, N>(&self, property_name: N) -> Result<Value, BoolError> where
N: Into<&'a str>, [src]
N: Into<&'a str>,
unsafe fn set_qdata<QD>(&self, key: Quark, value: QD) where
QD: 'static, [src]
QD: 'static,
unsafe fn get_qdata<QD>(&self, key: Quark) -> Option<&QD> where
QD: 'static, [src]
QD: 'static,
unsafe fn steal_qdata<QD>(&self, key: Quark) -> Option<QD> where
QD: 'static, [src]
QD: 'static,
unsafe fn set_data<QD>(&self, key: &str, value: QD) where
QD: 'static, [src]
QD: 'static,
unsafe fn get_data<QD>(&self, key: &str) -> Option<&QD> where
QD: 'static, [src]
QD: 'static,
unsafe fn steal_data<QD>(&self, key: &str) -> Option<QD> where
QD: 'static, [src]
QD: 'static,
fn block_signal(&self, handler_id: &SignalHandlerId)[src]
fn unblock_signal(&self, handler_id: &SignalHandlerId)[src]
fn stop_signal_emission(&self, signal_name: &str)[src]
fn disconnect(&self, handler_id: SignalHandlerId)[src]
fn connect_notify<F>(&self, name: Option<&str>, f: F) -> SignalHandlerId where
F: 'static + Send + Sync + Fn(&T, &ParamSpec), [src]
F: 'static + Send + Sync + Fn(&T, &ParamSpec),
unsafe fn connect_notify_unsafe<F>(
&self,
name: Option<&str>,
f: F
) -> SignalHandlerId where
F: Fn(&T, &ParamSpec), [src]
&self,
name: Option<&str>,
f: F
) -> SignalHandlerId where
F: Fn(&T, &ParamSpec),
fn notify<'a, N>(&self, property_name: N) where
N: Into<&'a str>, [src]
N: Into<&'a str>,
fn notify_by_pspec(&self, pspec: &ParamSpec)[src]
fn has_property<'a, N>(&self, property_name: N, type_: Option<Type>) -> bool where
N: Into<&'a str>, [src]
N: Into<&'a str>,
fn get_property_type<'a, N>(&self, property_name: N) -> Option<Type> where
N: Into<&'a str>, [src]
N: Into<&'a str>,
fn find_property<'a, N>(&self, property_name: N) -> Option<ParamSpec> where
N: Into<&'a str>, [src]
N: Into<&'a str>,
fn list_properties(&self) -> Vec<ParamSpec>[src]
fn connect<'a, N, F>(
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value> + Send + Sync + 'static,
N: Into<&'a str>, [src]
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value> + Send + Sync + 'static,
N: Into<&'a str>,
fn connect_local<'a, N, F>(
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value> + 'static,
N: Into<&'a str>, [src]
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value> + 'static,
N: Into<&'a str>,
unsafe fn connect_unsafe<'a, N, F>(
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value>,
N: Into<&'a str>, [src]
&self,
signal_name: N,
after: bool,
callback: F
) -> Result<SignalHandlerId, BoolError> where
F: Fn(&[Value]) -> Option<Value>,
N: Into<&'a str>,
fn emit<'a, N>(
&self,
signal_name: N,
args: &[&dyn ToValue]
) -> Result<Option<Value>, BoolError> where
N: Into<&'a str>, [src]
&self,
signal_name: N,
args: &[&dyn ToValue]
) -> Result<Option<Value>, BoolError> where
N: Into<&'a str>,
fn downgrade(&self) -> WeakRef<T>[src]
fn bind_property<'a, O, N, M>(
&'a self,
source_property: N,
target: &'a O,
target_property: M
) -> BindingBuilder<'a> where
M: Into<&'a str>,
N: Into<&'a str>,
O: ObjectType, [src]
&'a self,
source_property: N,
target: &'a O,
target_property: M
) -> BindingBuilder<'a> where
M: Into<&'a str>,
N: Into<&'a str>,
O: ObjectType,
fn ref_count(&self) -> u32[src]
impl<'a, T> ToGlibContainerFromSlice<'a, *const GList> for T where
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>, [src]
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>,
type Storage = (Option<List>, Vec<Stash<'a, <T as GlibPtrDefault>::GlibType, T>>)
fn to_glib_none_from_slice(
t: &'a [T]
) -> (*const GList, <T as ToGlibContainerFromSlice<'a, *const GList>>::Storage)[src]
t: &'a [T]
) -> (*const GList, <T as ToGlibContainerFromSlice<'a, *const GList>>::Storage)
fn to_glib_container_from_slice(
_t: &'a [T]
) -> (*const GList, <T as ToGlibContainerFromSlice<'a, *const GList>>::Storage)[src]
_t: &'a [T]
) -> (*const GList, <T as ToGlibContainerFromSlice<'a, *const GList>>::Storage)
fn to_glib_full_from_slice(_t: &[T]) -> *const GList[src]
impl<'a, T> ToGlibContainerFromSlice<'a, *const GPtrArray> for T where
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>, [src]
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>,
type Storage = (Option<PtrArray>, Vec<Stash<'a, <T as GlibPtrDefault>::GlibType, T>>)
fn to_glib_none_from_slice(
t: &'a [T]
) -> (*const GPtrArray, <T as ToGlibContainerFromSlice<'a, *const GPtrArray>>::Storage)[src]
t: &'a [T]
) -> (*const GPtrArray, <T as ToGlibContainerFromSlice<'a, *const GPtrArray>>::Storage)
fn to_glib_container_from_slice(
_t: &'a [T]
) -> (*const GPtrArray, <T as ToGlibContainerFromSlice<'a, *const GPtrArray>>::Storage)[src]
_t: &'a [T]
) -> (*const GPtrArray, <T as ToGlibContainerFromSlice<'a, *const GPtrArray>>::Storage)
fn to_glib_full_from_slice(_t: &[T]) -> *const GPtrArray[src]
impl<'a, T> ToGlibContainerFromSlice<'a, *mut GArray> for T where
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>, [src]
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>,
type Storage = (Option<Array>, Vec<Stash<'a, <T as GlibPtrDefault>::GlibType, T>>)
fn to_glib_none_from_slice(
t: &'a [T]
) -> (*mut GArray, <T as ToGlibContainerFromSlice<'a, *mut GArray>>::Storage)[src]
t: &'a [T]
) -> (*mut GArray, <T as ToGlibContainerFromSlice<'a, *mut GArray>>::Storage)
fn to_glib_container_from_slice(
t: &'a [T]
) -> (*mut GArray, <T as ToGlibContainerFromSlice<'a, *mut GArray>>::Storage)[src]
t: &'a [T]
) -> (*mut GArray, <T as ToGlibContainerFromSlice<'a, *mut GArray>>::Storage)
fn to_glib_full_from_slice(t: &[T]) -> *mut GArray[src]
impl<'a, T> ToGlibContainerFromSlice<'a, *mut GList> for T where
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>, [src]
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>,
type Storage = (Option<List>, Vec<Stash<'a, <T as GlibPtrDefault>::GlibType, T>>)
fn to_glib_none_from_slice(
t: &'a [T]
) -> (*mut GList, <T as ToGlibContainerFromSlice<'a, *mut GList>>::Storage)[src]
t: &'a [T]
) -> (*mut GList, <T as ToGlibContainerFromSlice<'a, *mut GList>>::Storage)
fn to_glib_container_from_slice(
t: &'a [T]
) -> (*mut GList, <T as ToGlibContainerFromSlice<'a, *mut GList>>::Storage)[src]
t: &'a [T]
) -> (*mut GList, <T as ToGlibContainerFromSlice<'a, *mut GList>>::Storage)
fn to_glib_full_from_slice(t: &[T]) -> *mut GList[src]
impl<'a, T> ToGlibContainerFromSlice<'a, *mut GPtrArray> for T where
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>, [src]
T: GlibPtrDefault + ToGlibPtr<'a, <T as GlibPtrDefault>::GlibType>,
type Storage = (Option<PtrArray>, Vec<Stash<'a, <T as GlibPtrDefault>::GlibType, T>>)
fn to_glib_none_from_slice(
t: &'a [T]
) -> (*mut GPtrArray, <T as ToGlibContainerFromSlice<'a, *mut GPtrArray>>::Storage)[src]
t: &'a [T]
) -> (*mut GPtrArray, <T as ToGlibContainerFromSlice<'a, *mut GPtrArray>>::Storage)
fn to_glib_container_from_slice(
t: &'a [T]
) -> (*mut GPtrArray, <T as ToGlibContainerFromSlice<'a, *mut GPtrArray>>::Storage)[src]
t: &'a [T]
) -> (*mut GPtrArray, <T as ToGlibContainerFromSlice<'a, *mut GPtrArray>>::Storage)
fn to_glib_full_from_slice(t: &[T]) -> *mut GPtrArray[src]
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T[src]
fn clone_into(&self, target: &mut T)[src]
impl<T> ToSendValue for T where
T: ToValue + SetValue + Send + ?Sized, [src]
T: ToValue + SetValue + Send + ?Sized,
fn to_send_value(&self) -> SendValue[src]
impl<T> ToValue for T where
T: SetValue + ?Sized, [src]
T: SetValue + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<O> URIHandlerExt for O where
O: IsA<URIHandler>, [src]
O: IsA<URIHandler>,