Add ClosePipes() to release output reading goroutines

livepeer · Jun 7, 2022 · cf66c9a · cf66c9a
1 parent 52ebd95
commit cf66c9a
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/ffmpeg/piped_transcode.go b/ffmpeg/piped_transcode.go
@@ -34,6 +34,15 @@ type PipedTranscoding struct {
 	outputs []PipedOutput
 }
 
+func (t *PipedTranscoding) ClosePipes() {
+	t.input.Read.Close()
+	t.input.Write.Close()
+	for i := 0; i < len(t.outputs); i++ {
+		t.outputs[i].Read.Close()
+		t.outputs[i].Write.Close()
+	}
+}
+
 func (t *PipedTranscoding) SetInput(input TranscodeOptionsIn) error {
 	t.input.Options = &input
 	var err error