(f func(sub ISubscriber, wait *waitTracks))
| 56 | } |
| 57 | |
| 58 | func (s *Subscribers) rangeAll(f func(sub ISubscriber, wait *waitTracks)) { |
| 59 | for sub, wait := range s.internal { |
| 60 | f(sub, wait) |
| 61 | } |
| 62 | for sub, wait := range s.public { |
| 63 | f(sub, wait) |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | func (s *Subscribers) OnTrack(track common.Track) { |
| 68 | s.rangeAll(func(sub ISubscriber, wait *waitTracks) { |
no outgoing calls
no test coverage detected