(message string)
| 31 | } |
| 32 | |
| 33 | func (channel *ChannelBefore) broadcast(message string) { |
| 34 | // channel.mu must be held |
| 35 | for name, client := range channel.clients { |
| 36 | n, err := client.Write([]byte(message)) |
| 37 | if err != nil || n != len(message) { |
| 38 | channel.disconnect(name) |
| 39 | } |
| 40 | } |
| 41 | } |
no test coverage detected