Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/sdroege/gst-plugin-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSebastian Dröge <sebastian@centricular.com>2022-01-19 16:07:45 +0300
committerSebastian Dröge <sebastian@centricular.com>2022-01-19 16:07:45 +0300
commit65fcd55160d126c549a89b613cdf84714a5b346e (patch)
tree83bd17f3deb9bc37ffa23b9819798ae744705c4a /utils/uriplaylistbin
parent763ad0cb184e9b68bd215c9e5fe63f391a581e2d (diff)
Update for event/message/query view API changes
Diffstat (limited to 'utils/uriplaylistbin')
-rw-r--r--utils/uriplaylistbin/src/uriplaylistbin/imp.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
index e4f4091e..33c953c4 100644
--- a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
+++ b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
@@ -436,7 +436,7 @@ impl Item {
// from the WaitingForStreamCollection state, called when we received the item stream collection
// and its stream topology matches what is currently being processed by the element.
- fn set_waiting_for_pads(&self, n_streams: u32, msg: gst::message::StreamCollection) {
+ fn set_waiting_for_pads(&self, n_streams: u32, msg: &gst::message::StreamCollection) {
let mut inner = self.inner.lock().unwrap();
assert!(matches!(
inner.state,
@@ -463,7 +463,7 @@ impl Item {
// from the WaitingForStreamCollection state, called when we received the item stream collection
// but its stream topology does not match what is currently being processed by the element,
// having to wait until streamsynchronizer is flushed to internally reorganize the element.
- fn set_waiting_for_ss_eos(&self, waiting_eos: u32, msg: gst::message::StreamCollection) {
+ fn set_waiting_for_ss_eos(&self, waiting_eos: u32, msg: &gst::message::StreamCollection) {
let mut inner = self.inner.lock().unwrap();
let (sender, receiver) = crossbeam_channel::unbounded::<bool>();
@@ -1111,7 +1111,7 @@ impl UriPlaylistBin {
fn handle_stream_collection(
&self,
element: &super::UriPlaylistBin,
- stream_collection_msg: gst::message::StreamCollection,
+ stream_collection_msg: &gst::message::StreamCollection,
) -> Result<(), PlaylistError> {
let mut state_guard = self.state.lock().unwrap();
let state = state_guard.as_mut().unwrap();
@@ -1168,7 +1168,7 @@ impl UriPlaylistBin {
fn handle_stream_selected(
&self,
element: &super::UriPlaylistBin,
- stream_selected_msg: gst::message::StreamsSelected,
+ stream_selected_msg: &gst::message::StreamsSelected,
) -> bool {
let mut state_guard = self.state.lock().unwrap();
let state = state_guard.as_mut().unwrap();