diff --git a/app/src/stream.c b/app/src/stream.c
index 30151859..e85834c1 100644
--- a/app/src/stream.c
+++ b/app/src/stream.c
@@ -198,7 +198,7 @@ run_stream(void *data) {
 
     if (stream->recorder && !recorder_open(stream->recorder, codec)) {
         LOGE("Could not open recorder");
-        goto finally_close_input;
+        goto finally_close_decoder;
     }
 
     AVPacket packet;
@@ -248,6 +248,10 @@ quit:
     if (stream->recorder) {
         recorder_close(stream->recorder);
     }
+finally_close_decoder:
+    if (stream->decoder) {
+        decoder_close(stream->decoder);
+    }
 finally_close_input:
     avformat_close_input(&format_ctx);
 finally_free_avio_ctx: