diff options
Diffstat (limited to 'generic/threadshare/src/appsrc.rs')
| -rw-r--r-- | generic/threadshare/src/appsrc.rs | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/generic/threadshare/src/appsrc.rs b/generic/threadshare/src/appsrc.rs index 1c315b40e..ea33a9bb6 100644 --- a/generic/threadshare/src/appsrc.rs +++ b/generic/threadshare/src/appsrc.rs @@ -182,14 +182,13 @@ impl AppSrcPadHandler { gst_debug!(CAT, obj: pad.gst_pad(), "Pushing initial events"); let stream_id = format!("{:08x}{:08x}", rand::random::<u32>(), rand::random::<u32>()); - let stream_start_evt = gst::Event::new_stream_start(&stream_id) + let stream_start_evt = gst::event::StreamStart::builder(&stream_id) .group_id(gst::GroupId::next()) .build(); pad.push_event(stream_start_evt).await; if let Some(ref caps) = state.caps { - let caps_evt = gst::Event::new_caps(&caps).build(); - pad.push_event(caps_evt).await; + pad.push_event(gst::event::Caps::new(&caps)).await; *self.0.configured_caps.lock().unwrap() = Some(caps.clone()); } @@ -198,7 +197,7 @@ impl AppSrcPadHandler { if state.need_segment { let segment_evt = - gst::Event::new_segment(&gst::FormattedSegment::<gst::format::Time>::new()).build(); + gst::event::Segment::new(&gst::FormattedSegment::<gst::format::Time>::new()); pad.push_event(segment_evt).await; state.need_segment = false; @@ -374,8 +373,7 @@ impl TaskImpl for AppSrcTask { } Err(gst::FlowError::Eos) => { gst_debug!(CAT, obj: &self.element, "EOS"); - let eos = gst::Event::new_eos().build(); - pad.push_event(eos).await; + pad.push_event(gst::event::Eos::new()).await; } Err(gst::FlowError::Flushing) => { gst_debug!(CAT, obj: &self.element, "Flushing"); @@ -478,8 +476,7 @@ impl AppSrc { None => return false, }; - let eos = StreamItem::Event(gst::Event::new_eos().build()); - match sender.try_send(eos) { + match sender.try_send(StreamItem::Event(gst::event::Eos::new())) { Ok(_) => true, Err(err) => { gst_error!(CAT, obj: element, "Failed to queue EOS: {}", err); |