diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index 678765cce..5eaaad4a0 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -841,6 +841,9 @@ func (p *ParticipantImpl) downTracksRTCPWorker() { for { time.Sleep(5 * time.Second) + if p.State() == livekit.ParticipantInfo_DISCONNECTED { + return + } if p.subscriber.pc.ConnectionState() != webrtc.PeerConnectionStateConnected { continue }