diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2022-01-19 16:07:45 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2022-01-19 16:07:45 +0300 |
commit | 65fcd55160d126c549a89b613cdf84714a5b346e (patch) | |
tree | 83bd17f3deb9bc37ffa23b9819798ae744705c4a /utils/uriplaylistbin | |
parent | 763ad0cb184e9b68bd215c9e5fe63f391a581e2d (diff) |
Update for event/message/query view API changes
Diffstat (limited to 'utils/uriplaylistbin')
-rw-r--r-- | utils/uriplaylistbin/src/uriplaylistbin/imp.rs | 8 |
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(); |