From 4f947ad6510d0cc3294ad672450b9f61031f6130 Mon Sep 17 00:00:00 2001
From: Yohann D'ANELLO <yohann.danello@gmail.com>
Date: Sun, 8 Nov 2020 15:29:18 +0100
Subject: [PATCH] Bufferize reading

---
 stream/webrtc/ingest.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/stream/webrtc/ingest.go b/stream/webrtc/ingest.go
index ff85f90..82f0480 100644
--- a/stream/webrtc/ingest.go
+++ b/stream/webrtc/ingest.go
@@ -31,7 +31,7 @@ func ingest(name string, q *messaging.Quality) {
 		return
 	}
 
-	// Start ffmpag to convert videoInput to audio UDP
+	// Start ffmpeg to convert videoInput to audio UDP
 	ffmpeg, ffmpegOut, err := startFFmpeg(videoInput, firstPort)
 	if err != nil {
 		log.Printf("Error while starting ffmpeg: %s", err)
@@ -40,7 +40,7 @@ func ingest(name string, q *messaging.Quality) {
 
 	// Receive video
 	go func() {
-		h264, _ := h264reader.NewReader(*ffmpegOut)
+		h264, _ := h264reader.NewReader(bufio.NewReader(*ffmpegOut))
 		var spsAndPpsCache []byte
 
 		for {