(evt message.Event)
| 373 | } |
| 374 | |
| 375 | func (s *MockServer) Event(evt message.Event) { |
| 376 | s.clients.Range(func(key, _ interface{}) bool { |
| 377 | cl := key.(*MockClient) |
| 378 | cl.events <- evt |
| 379 | return true |
| 380 | }) |
| 381 | } |
| 382 | |
| 383 | func (s *MockServer) copyPeers() []MockHost { |
| 384 | s.mu.Lock() |
no outgoing calls