mirror of
https://github.com/livekit/livekit.git
synced 2026-03-29 09:19:53 +00:00
@@ -555,13 +555,7 @@ func (c *RTCClient) sendRequest(msg *livekit.SignalRequest) error {
|
||||
}
|
||||
|
||||
func (c *RTCClient) SendIceCandidate(ic *webrtc.ICECandidate, target livekit.SignalTarget) error {
|
||||
var icQueue *atomic.Pointer[webrtc.ICECandidate]
|
||||
if target == livekit.SignalTarget_PUBLISHER {
|
||||
icQueue = &c.icQueue[0]
|
||||
} else {
|
||||
icQueue = &c.icQueue[1]
|
||||
}
|
||||
prevIC := icQueue.Swap(ic)
|
||||
prevIC := c.icQueue[target].Swap(ic)
|
||||
if prevIC == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user