(msg *livekit.WorkerMessage)
| 173 | } |
| 174 | |
| 175 | func (c *agentClient) write(msg *livekit.WorkerMessage) error { |
| 176 | c.mu.Lock() |
| 177 | defer c.mu.Unlock() |
| 178 | |
| 179 | select { |
| 180 | case <-c.done: |
| 181 | return nil |
| 182 | default: |
| 183 | b, err := proto.Marshal(msg) |
| 184 | if err != nil { |
| 185 | return err |
| 186 | } |
| 187 | |
| 188 | return c.conn.WriteMessage(websocket.BinaryMessage, b) |
| 189 | } |
| 190 | } |
| 191 | |
| 192 | func (c *agentClient) close() { |
| 193 | c.mu.Lock() |
no test coverage detected