diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2022-10-19 19:18:43 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2022-10-19 19:43:29 +0300 |
commit | 12400b6b87e75cfdfa7701b62cf8698c11e14a73 (patch) | |
tree | df8f49f8258a34e961b8f9710671fc0d97bf7c58 /generic/threadshare/tests/jitterbuffer.rs | |
parent | 9ce8e93c6374a712a6c8981557c726a3fc04273b (diff) |
Update everything for element factory builder API changes
And set properties as part of object construction wherever it makes
sense.
Diffstat (limited to 'generic/threadshare/tests/jitterbuffer.rs')
-rw-r--r-- | generic/threadshare/tests/jitterbuffer.rs | 109 |
1 files changed, 76 insertions, 33 deletions
diff --git a/generic/threadshare/tests/jitterbuffer.rs b/generic/threadshare/tests/jitterbuffer.rs index b5d5a6b9f..2904384b7 100644 --- a/generic/threadshare/tests/jitterbuffer.rs +++ b/generic/threadshare/tests/jitterbuffer.rs @@ -51,25 +51,45 @@ fn jb_pipeline() { let pipeline = gst::Pipeline::new(None); - let src = gst::ElementFactory::make("audiotestsrc", Some("audiotestsrc")).unwrap(); - src.set_property("is-live", true); - src.set_property("num-buffers", BUFFER_NB); + let src = gst::ElementFactory::make("audiotestsrc") + .name("audiotestsrc") + .property("is-live", true) + .property("num-buffers", BUFFER_NB) + .build() + .unwrap(); - let enc = gst::ElementFactory::make("alawenc", Some("alawenc")).unwrap(); - let pay = gst::ElementFactory::make("rtppcmapay", Some("rtppcmapay")).unwrap(); + let enc = gst::ElementFactory::make("alawenc") + .name("alawenc") + .build() + .unwrap(); + let pay = gst::ElementFactory::make("rtppcmapay") + .name("rtppcmapay") + .build() + .unwrap(); - let jb = gst::ElementFactory::make("ts-jitterbuffer", Some("ts-jitterbuffer")).unwrap(); - jb.set_property("context", "jb_pipeline"); - jb.set_property("context-wait", CONTEXT_WAIT); - jb.set_property("latency", LATENCY); + let jb = gst::ElementFactory::make("ts-jitterbuffer") + .name("ts-jitterbuffer") + .property("context", "jb_pipeline") + .property("context-wait", CONTEXT_WAIT) + .property("latency", LATENCY) + .build() + .unwrap(); - let depay = gst::ElementFactory::make("rtppcmadepay", Some("rtppcmadepay")).unwrap(); - let dec = gst::ElementFactory::make("alawdec", Some("alawdec")).unwrap(); + let depay = gst::ElementFactory::make("rtppcmadepay") + .name("rtppcmadepay") + .build() + .unwrap(); + let dec = gst::ElementFactory::make("alawdec") + .name("alawdec") + .build() + .unwrap(); - let sink = gst::ElementFactory::make("appsink", Some("appsink")).unwrap(); - sink.set_property("sync", false); - sink.set_property("async", false); - sink.set_property("emit-signals", true); + let sink = gst::ElementFactory::make("appsink") + .name("appsink") + .property("sync", false) + .property("async", false) + .build() + .unwrap(); pipeline .add_many(&[&src, &enc, &pay, &jb, &depay, &dec, &sink]) @@ -110,29 +130,52 @@ fn jb_ts_pipeline() { let pipeline = gst::Pipeline::new(None); - let src = gst::ElementFactory::make("audiotestsrc", Some("audiotestsrc")).unwrap(); - src.set_property("is-live", true); - src.set_property("num-buffers", BUFFER_NB); + let src = gst::ElementFactory::make("audiotestsrc") + .name("audiotestsrc") + .property("is-live", true) + .property("num-buffers", BUFFER_NB) + .build() + .unwrap(); - let queue = gst::ElementFactory::make("ts-queue", Some("ts-queue")).unwrap(); - queue.set_property("context", "jb_ts_pipeline_queue"); - queue.set_property("context-wait", CONTEXT_WAIT); + let queue = gst::ElementFactory::make("ts-queue") + .name("ts-queue") + .property("context", "jb_ts_pipeline_queue") + .property("context-wait", CONTEXT_WAIT) + .build() + .unwrap(); - let enc = gst::ElementFactory::make("alawenc", Some("alawenc")).unwrap(); - let pay = gst::ElementFactory::make("rtppcmapay", Some("rtppcmapay")).unwrap(); + let enc = gst::ElementFactory::make("alawenc") + .name("alawenc") + .build() + .unwrap(); + let pay = gst::ElementFactory::make("rtppcmapay") + .name("rtppcmapay") + .build() + .unwrap(); - let jb = gst::ElementFactory::make("ts-jitterbuffer", Some("ts-jitterbuffer")).unwrap(); - jb.set_property("context", "jb_ts_pipeline"); - jb.set_property("context-wait", CONTEXT_WAIT); - jb.set_property("latency", LATENCY); + let jb = gst::ElementFactory::make("ts-jitterbuffer") + .name("ts-jitterbuffer") + .property("context", "jb_ts_pipeline") + .property("context-wait", CONTEXT_WAIT) + .property("latency", LATENCY) + .build() + .unwrap(); - let depay = gst::ElementFactory::make("rtppcmadepay", Some("rtppcmadepay")).unwrap(); - let dec = gst::ElementFactory::make("alawdec", Some("alawdec")).unwrap(); + let depay = gst::ElementFactory::make("rtppcmadepay") + .name("rtppcmadepay") + .build() + .unwrap(); + let dec = gst::ElementFactory::make("alawdec") + .name("alawdec") + .build() + .unwrap(); - let sink = gst::ElementFactory::make("appsink", Some("appsink")).unwrap(); - sink.set_property("sync", false); - sink.set_property("async", false); - sink.set_property("emit-signals", true); + let sink = gst::ElementFactory::make("appsink") + .name("appsink") + .property("sync", false) + .property("async", false) + .build() + .unwrap(); pipeline .add_many(&[&src, &queue, &enc, &pay, &jb, &depay, &dec, &sink]) |