(trackID livekit.TrackID)
| 679 | } |
| 680 | |
| 681 | func (m *SubscriptionManager) queueReconcileDataTrack(trackID livekit.TrackID) { |
| 682 | select { |
| 683 | case m.reconcileDataTrackCh <- trackID: |
| 684 | default: |
| 685 | // queue is full, will reconcile based on timer |
| 686 | } |
| 687 | } |
| 688 | |
| 689 | func (m *SubscriptionManager) reconcileWorker() { |
| 690 | defer close(m.doneCh) |
no outgoing calls
no test coverage detected