(msg *livekit.SignalRequest)
| 832 | } |
| 833 | |
| 834 | func (c *RTCClient) sendRequest(msg *livekit.SignalRequest) error { |
| 835 | payload, err := proto.Marshal(msg) |
| 836 | if err != nil { |
| 837 | return err |
| 838 | } |
| 839 | |
| 840 | c.wsLock.Lock() |
| 841 | defer c.wsLock.Unlock() |
| 842 | return c.conn.WriteMessage(websocket.BinaryMessage, payload) |
| 843 | } |
| 844 | |
| 845 | func (c *RTCClient) SendIceCandidate(ic *webrtc.ICECandidate, target livekit.SignalTarget) error { |
| 846 | prevIC := c.icQueue[target].Swap(ic) |
no test coverage detected