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 {