diff --git a/pkg/rtc/mediatrackreceiver.go b/pkg/rtc/mediatrackreceiver.go index d14df48e7..01b58c800 100644 --- a/pkg/rtc/mediatrackreceiver.go +++ b/pkg/rtc/mediatrackreceiver.go @@ -90,6 +90,14 @@ func (t *MediaTrackReceiver) SetupReceiver(receiver sfu.TrackReceiver) { t.MediaTrackSubscriptions.Start() } +func (t *MediaTrackReceiver) ClearReceiver() { + t.lock.Lock() + t.receiver = nil + t.lock.Unlock() + + t.MediaTrackSubscriptions.Close() +} + func (t *MediaTrackReceiver) OnMediaLossUpdate(f func(fractionalLoss uint8)) { t.onMediaLossUpdate = f }