Flush the AsyncQueue when the stream ends.

svn path=/trunk/; revision=438

diff --git a/src/rygel/rygel-gst-stream.vala b/src/rygel/rygel-gst-stream.vala
index c31fa78..fa13c06 100644 (file)
--- a/src/rygel/rygel-gst-stream.vala
+++ b/src/rygel/rygel-gst-stream.vala
@@ -63,6 +63,11 @@ public class Rygel.GstStream : Rygel.Stream {
 
     public override void end (bool aborted) {
         this.pipeline.set_state (State.NULL);
+        // Flush the queue of buffers
+        Buffer buffer = null;
+        do {
+            buffer = this.buffers.try_pop ();
+        } while (buffer != null);
 
         base.end (aborted);
     }