diff --git a/pkg/rtc/dynacastmanager.go b/pkg/rtc/dynacastmanager.go index 1de8d4d2a..ca6ea7af3 100644 --- a/pkg/rtc/dynacastmanager.go +++ b/pkg/rtc/dynacastmanager.go @@ -96,7 +96,7 @@ func (d *DynacastManager) Restart() { } func (d *DynacastManager) Close() { - <-d.qualityNotifyOpQueue.Stop() + d.qualityNotifyOpQueue.Stop() d.lock.Lock() dqs := d.getDynacastQualitiesLocked()