(m *livekit.ServerMessage)
| 256 | } |
| 257 | |
| 258 | func (w *AgentWorker) WriteServerMessage(m *livekit.ServerMessage) (int, error) { |
| 259 | w.mu.Lock() |
| 260 | defer w.mu.Unlock() |
| 261 | w.serverMessages.PushBack(m) |
| 262 | if w.serverMessages.Len() == 1 { |
| 263 | go w.handleServerMessages() |
| 264 | } |
| 265 | return 0, nil |
| 266 | } |
| 267 | |
| 268 | func (w *AgentWorker) handleServerMessages() { |
| 269 | w.mu.Lock() |
nothing calls this directly
no test coverage detected