mirror of
https://github.com/livekit/livekit.git
synced 2026-10-22 21:53:22 +00:00
Add ResyncDownTracks API that can be used to resync all down tracks on (#3185)
* Add ResyncDownTracks API that can be used to resync all down tracks on these receivers. * actually call the function
This commit is contained in:
1 parent
cd718c84f6
commit
d0343808f2
2 files changed
+12
No files matched your search
@@ -121,6 +121,12 @@ func (r *RedPrimaryReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID)
|
||||
r.logger.Debugw("red primary receiver downtrack deleted", "subscriberID", subscriberID)
|
||||
}
|
||||
|
||||
func (r *RedPrimaryReceiver) ResyncDownTracks() {
|
||||
r.downTrackSpreader.Broadcast(func(dt TrackSender) {
|
||||
dt.Resync()
|
||||
})
|
||||
}
|
||||
|
||||
func (r *RedPrimaryReceiver) IsClosed() bool {
|
||||
return r.closed.Load()
|
||||
}
|
||||
|
||||
@@ -112,6 +112,12 @@ func (r *RedReceiver) DeleteDownTrack(subscriberID livekit.ParticipantID) {
|
||||
r.logger.Debugw("red receiver downtrack deleted", "subscriberID", subscriberID)
|
||||
}
|
||||
|
||||
func (r *RedReceiver) ResyncDownTracks() {
|
||||
r.downTrackSpreader.Broadcast(func(dt TrackSender) {
|
||||
dt.Resync()
|
||||
})
|
||||
}
|
||||
|
||||
func (r *RedReceiver) CanClose() bool {
|
||||
return r.closed.Load() || r.downTrackSpreader.DownTrackCount() == 0
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user