diff --git a/stream/forwarding/forwarding_test.go b/stream/forwarding/forwarding_test.go index 0ce6a59..485a19f 100644 --- a/stream/forwarding/forwarding_test.go +++ b/stream/forwarding/forwarding_test.go @@ -77,5 +77,15 @@ func TestForwardStream(t *testing.T) { time.Sleep(5 * time.Second) // Delay is in nanoseconds, here 5s + err = ffmpeg.Process.Kill() + if err != nil { + t.Fatalf("Error while killing ffmpeg: already died?") + } + + err = forwardedFfmpeg.Process.Kill() + if err != nil { + t.Fatalf("Error while killing ffmpeg: already died?") + } + // TODO Kill SRT server }