From 138c318be691a9b2d1d0e91f112b1dc4bdc5ad48 Mon Sep 17 00:00:00 2001
From: Guillaume Desmottes <guillaume.desmottes@onestream.live>
Date: Fri, 27 Jan 2023 12:09:50 +0100
Subject: [PATCH] uriplaylistbin: example: add queues

Prevent pipeline starvation with some media such as
https://assets.onestream.live/studio/Videos/1080p/osl-interval-1080p-8.mp4

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1064>
---
 utils/uriplaylistbin/examples/playlist.rs | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/utils/uriplaylistbin/examples/playlist.rs b/utils/uriplaylistbin/examples/playlist.rs
index 804fdc73..94116d16 100644
--- a/utils/uriplaylistbin/examples/playlist.rs
+++ b/utils/uriplaylistbin/examples/playlist.rs
@@ -44,10 +44,13 @@ fn create_pipeline(uris: Vec<String>, iterations: u32) -> anyhow::Result<gst::Pi
         let pad_name = src_pad.name();
 
         let sink = if pad_name.starts_with("audio") {
-            gst::parse_bin_from_description("audioconvert ! audioresample ! autoaudiosink", true)
-                .unwrap()
+            gst::parse_bin_from_description(
+                "queue ! audioconvert ! audioresample ! autoaudiosink",
+                true,
+            )
+            .unwrap()
         } else if pad_name.starts_with("video") {
-            gst::parse_bin_from_description("videoconvert ! autovideosink", true).unwrap()
+            gst::parse_bin_from_description("queue ! videoconvert ! autovideosink", true).unwrap()
         } else {
             unimplemented!();
         };