consumeCandidate.ts

public candidateListen() {
        this.socket.candidateListen()
            .pipe(takeWhile(() => this.alive))
            .subscribe((data) => {
                let id: string = data.id;
                let candidate: RTCIceCandidate = new RTCIceCandidate(data.candidate);

                if (!this.peerConnections[id] || this.peerConnections[id] == null) {
                    this.peerConnections[id] = new RTCPeerConnection(this.connectionConfig);
                }

                this.peerConnections[id].addIceCandidate(candidate).then(() => {
                    console.log('addIceCandidate success');
                }).catch((err) => {
                    // console.log('err=>', err);
                });

            }, (err) => {
                console.log('err=>', err);
            })
    }