From 2d16ee8884119dc3e4d1f31017b591ba82347794 Mon Sep 17 00:00:00 2001
From: Alex X <alexey.khit@gmail.com>
Date: Mon, 13 Nov 2023 22:55:01 +0300
Subject: [PATCH] Code refactoring for mpegts input

---
 internal/mpegts/mpegts.go | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/internal/mpegts/mpegts.go b/internal/mpegts/mpegts.go
index 4d082c27..6f4f6ab2 100644
--- a/internal/mpegts/mpegts.go
+++ b/internal/mpegts/mpegts.go
@@ -56,19 +56,17 @@ func inputMpegTS(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	res := &http.Response{Body: r.Body, Request: r}
-	client, err := mpegts.Open(res.Body)
+	client, err := mpegts.Open(r.Body)
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusInternalServerError)
 		return
 	}
 
 	stream.AddProducer(client)
+	defer stream.RemoveProducer(client)
 
 	if err = client.Start(); err != nil {
 		http.Error(w, err.Error(), http.StatusInternalServerError)
 		return
 	}
-
-	stream.RemoveProducer(client)
 }