From e3c97941ec1ca0a81476286e3fefe76919f7a042 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fran=C3=A7ois=20Laignel?= <francois@centricular.com>
Date: Thu, 5 Jun 2025 12:47:08 +0200
Subject: [PATCH] ts: standalone example: add a ts-queue

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/2278>
---
 generic/threadshare/examples/standalone/main.rs | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/generic/threadshare/examples/standalone/main.rs b/generic/threadshare/examples/standalone/main.rs
index bc7551416..4c8d00747 100644
--- a/generic/threadshare/examples/standalone/main.rs
+++ b/generic/threadshare/examples/standalone/main.rs
@@ -47,6 +47,7 @@ fn main() {
     use std::time::Instant;
 
     gst::init().unwrap();
+    gstthreadshare::plugin_register_static().unwrap();
     self::plugin_register_static().unwrap();
 
     #[cfg(debug_assertions)]
@@ -68,6 +69,16 @@ fn main() {
             .build()
             .unwrap();
 
+        let queue = gst::ElementFactory::make("ts-queue")
+            .name(format!("queue-{i}").as_str())
+            .property("context", &ctx_name)
+            .property("context-wait", args.wait)
+            .property("max-size-buffers", 1u32)
+            .property("max-size-bytes", 0u32)
+            .property("max-size-time", 0u64)
+            .build()
+            .unwrap();
+
         let sink = gst::ElementFactory::make(args.sink.element_name())
             .name(format!("sink-{i}").as_str())
             .property("context", &ctx_name)
@@ -97,7 +108,7 @@ fn main() {
             }
         }
 
-        let elements = &[&src, &sink];
+        let elements = &[&src, &queue, &sink];
         pipeline.add_many(elements).unwrap();
         gst::Element::link_many(elements).unwrap();
     }