(track common.Track)
| 65 | } |
| 66 | |
| 67 | func (s *Subscribers) OnTrack(track common.Track) { |
| 68 | s.rangeAll(func(sub ISubscriber, wait *waitTracks) { |
| 69 | if _, ok := s.waits[wait]; ok { |
| 70 | if wait.Accept(track) { |
| 71 | delete(s.waits, wait) |
| 72 | } |
| 73 | } else { |
| 74 | sub.OnEvent(track) |
| 75 | } |
| 76 | }) |
| 77 | } |
| 78 | |
| 79 | func (s *Subscribers) OnPublisherLost(event StateEvent) { |
| 80 | s.rangeAll(func(sub ISubscriber, wait *waitTracks) { |