(m CopilotWebSocketMessage)
| 506 | } |
| 507 | |
| 508 | func (q *frameQueue) push(m CopilotWebSocketMessage) { |
| 509 | q.mu.Lock() |
| 510 | if !q.done { |
| 511 | q.items = append(q.items, m) |
| 512 | } |
| 513 | q.cond.Signal() |
| 514 | q.mu.Unlock() |
| 515 | } |
| 516 | |
| 517 | func (q *frameQueue) close() { |
| 518 | q.mu.Lock() |