fix(ice): add buffered candidates (#318)

ionorg · Nov 24, 2020 · cd896a6 · cd896a6
1 parent 6e511c3
commit cd896a6
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/pkg/publisher.go b/pkg/publisher.go
@@ -81,6 +81,12 @@ func (p *Publisher) Answer(offer webrtc.SessionDescription) (webrtc.SessionDescr
 	if err := p.pc.SetRemoteDescription(offer); err != nil {
 		return webrtc.SessionDescription{}, err
 	}
+
+	for _, c := range p.candidates {
+		p.pc.AddICECandidate(c)
+		p.candidates = nil
+	}
+
 	answer, err := p.pc.CreateAnswer(nil)
 	if err != nil {
 		return webrtc.SessionDescription{}, err

diff --git a/pkg/subscriber.go b/pkg/subscriber.go
@@ -205,6 +205,12 @@ func (s *Subscriber) SetRemoteDescription(desc webrtc.SessionDescription) error
 		log.Errorf("SetRemoteDescription error: %v", err)
 		return err
 	}
+
+	for _, c := range s.candidates {
+		s.pc.AddICECandidate(c)
+		s.candidates = nil
+	}
+
 	return nil
 }