diff --git a/src/muxer/tvh/mkmux.c b/src/muxer/tvh/mkmux.c
index 587dc755..258a5438 100644
--- a/src/muxer/tvh/mkmux.c
+++ b/src/muxer/tvh/mkmux.c
@@ -998,6 +998,8 @@ mk_mux_init(mk_mux_t *mkm, const char *title, const streaming_start_t *ss)
  
   mk_write_queue(mkm, &q);
 
+  htsbuf_queue_flush(&q);
+
   return mkm->error;
 }