ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-browser: individual ICE candidate list to support signalingstate

pull/88/merge
pabloFuente 2018-06-19 14:32:23 +02:00
parent 65cdea70f6
commit 4e0092614d
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
openvidu-browser/src/OpenViduInternal/WebRtcPeer/WebRtcPeer.ts
View File

@ -40,6 +40,8 @@ export class WebRtcPeer {
remoteCandidatesQueue: RTCIceCandidate[] = []; remoteCandidatesQueue: RTCIceCandidate[] = [];
localCandidatesQueue: RTCIceCandidate[] = []; localCandidatesQueue: RTCIceCandidate[] = [];
iceCandidateList: RTCIceCandidate[] = [];
private candidategatheringdone = false; private candidategatheringdone = false;
constructor(private configuration: WebRtcPeerConfiguration) { constructor(private configuration: WebRtcPeerConfiguration) {
@ -61,12 +63,9 @@ export class WebRtcPeer {
this.pc.onsignalingstatechange = () => { this.pc.onsignalingstatechange = () => {
if (this.pc.signalingState === 'stable') { if (this.pc.signalingState === 'stable') {
for (const candidate of this.remoteCandidatesQueue) { while (this.iceCandidateList.length > 0) {
this.pc.addIceCandidate(<RTCIceCandidate>candidate); this.pc.addIceCandidate(<RTCIceCandidate>this.iceCandidateList.shift());
} }
/*while (this.remoteCandidatesQueue.length > 0) {
this.pc.addIceCandidate(<RTCIceCandidate>this.remoteCandidatesQueue.shift());
}*/
} }
}; };
@ -228,6 +227,7 @@ export class WebRtcPeer {
addIceCandidate(iceCandidate: RTCIceCandidate): Promise<void> { addIceCandidate(iceCandidate: RTCIceCandidate): Promise<void> {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
console.debug('Remote ICE candidate received', iceCandidate); console.debug('Remote ICE candidate received', iceCandidate);
this.remoteCandidatesQueue.push(iceCandidate);
switch (this.pc.signalingState) { switch (this.pc.signalingState) {
case 'closed': case 'closed':
reject(new Error('PeerConnection object is closed')); reject(new Error('PeerConnection object is closed'));
@ -238,7 +238,7 @@ export class WebRtcPeer {
} }
break; break;
default: default:
this.remoteCandidatesQueue.push(iceCandidate); this.iceCandidateList.push(iceCandidate);
resolve(); resolve();
} }
}); });