(b []byte)
| 121 | } |
| 122 | |
| 123 | func (s *Server) Send(b []byte) { |
| 124 | var wg sync.WaitGroup |
| 125 | for _, conn := range s.snapshot() { |
| 126 | wg.Add(1) |
| 127 | go func() { |
| 128 | defer wg.Done() |
| 129 | conn.Write(context.Background(), websocket.MessageBinary, b) |
| 130 | }() |
| 131 | } |
| 132 | wg.Wait() |
| 133 | } |
| 134 | |
| 135 | func (s *Server) websocket(w http.ResponseWriter, r *http.Request) { |
| 136 | conn, err := websocket.Accept(w, r, &websocket.AcceptOptions{InsecureSkipVerify: true}) |