diff options
Diffstat (limited to 'generic/threadshare/src/queue.rs')
| -rw-r--r-- | generic/threadshare/src/queue.rs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/generic/threadshare/src/queue.rs b/generic/threadshare/src/queue.rs index dfdb648d8..e07c9cca2 100644 --- a/generic/threadshare/src/queue.rs +++ b/generic/threadshare/src/queue.rs @@ -350,7 +350,7 @@ impl PadSrcHandler for QueuePadSrcHandler { gst_log!(CAT, obj: pad.gst_pad(), "Handling {:?}", query); if let QueryView::Scheduling(ref mut q) = query.view_mut() { - let mut new_query = gst::Query::new_scheduling(); + let mut new_query = gst::query::Scheduling::new(); let res = queue.sink_pad.gst_pad().peer_query(&mut new_query); if !res { return res; @@ -439,8 +439,7 @@ impl TaskImpl for QueueTask { Err(gst::FlowError::Eos) => { gst_debug!(CAT, obj: &self.element, "EOS"); *queue.last_res.lock().unwrap() = Err(gst::FlowError::Eos); - let eos = gst::Event::new_eos().build(); - pad.push_event(eos).await; + pad.push_event(gst::event::Eos::new()).await; } Err(err) => { gst_error!(CAT, obj: &self.element, "Got error {}", err); |