()
| 22 | } |
| 23 | |
| 24 | func (s *Subscribers) MarshalJSON() ([]byte, error) { |
| 25 | var subers []ISubscriber |
| 26 | for suber := range s.public { |
| 27 | subers = append(subers, suber) |
| 28 | } |
| 29 | return json.Marshal(subers) |
| 30 | } |
| 31 | |
| 32 | func (s *Subscribers) Broadcast(event any) { |
| 33 | for sub := range s.internal { |