do not reconnect after EOS (#464)

livekit · Aug 15, 2023 · 40f2969 · 40f2969
1 parent e20f32d
commit 40f2969
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/pipeline/watch.go b/pkg/pipeline/watch.go
@@ -177,7 +177,7 @@ func (p *Pipeline) handleMessageError(gErr *gst.GError) error {
 
 	switch {
 	case element == elementGstRtmp2Sink:
-		if strings.HasPrefix(gErr.Error(), "Connection error") {
+		if strings.HasPrefix(gErr.Error(), "Connection error") && !p.eosSent.IsBroken() {
 			// try reconnecting
 			ok, err := p.out.ResetStream(name, gErr)
 			if err != nil {