diff --git a/plugins/elements/gstqueue.c b/plugins/elements/gstqueue.c index 5bb6774078..46e969f15c 100644 --- a/plugins/elements/gstqueue.c +++ b/plugins/elements/gstqueue.c @@ -1089,7 +1089,7 @@ out_unexpected: static GstFlowReturn gst_queue_push_one (GstQueue * queue) { - GstFlowReturn result = GST_FLOW_OK; + GstFlowReturn result = queue->srcresult; GstMiniObject *data; data = gst_queue_locked_dequeue (queue); diff --git a/plugins/elements/gstqueue2.c b/plugins/elements/gstqueue2.c index d023d1c4df..36cd4055b8 100644 --- a/plugins/elements/gstqueue2.c +++ b/plugins/elements/gstqueue2.c @@ -2577,7 +2577,7 @@ gst_queue2_dequeue_on_eos (GstQueue2 * queue, GstQueue2ItemType * item_type) static GstFlowReturn gst_queue2_push_one (GstQueue2 * queue) { - GstFlowReturn result = GST_FLOW_OK; + GstFlowReturn result = queue->srcresult; GstMiniObject *data; GstQueue2ItemType item_type;