(event any)
| 30 | } |
| 31 | |
| 32 | func (s *Subscribers) Broadcast(event any) { |
| 33 | for sub := range s.internal { |
| 34 | sub.OnEvent(event) |
| 35 | } |
| 36 | for sub := range s.public { |
| 37 | sub.OnEvent(event) |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | func (s *Subscribers) Pick() ISubscriber { |
| 42 | for sub := range s.public { |