[mirotalksfu] - fix typo

هذا الالتزام موجود في:
Miroslav Pejic
2025-05-02 23:34:35 +02:00
الأصل d5a6678fe4
التزام 0abb7d3f58

عرض الملف

@@ -328,11 +328,18 @@ module.exports = class Room {
} }
closeRouter() { closeRouter() {
this.stopAudioLevelObserver(); if (this.router && !this.router.closed) {
this.stopActiveSpeakerObserver();
this.router.close(); this.router.close();
log.debug('Router closed', { router_id: this.router.id }); log.debug('Router closed', { router_id: this.router.id });
} }
}
close() {
this.closeAudioLevelObserver();
this.closeActiveSpeakerObserver();
this.closeRouter();
log.debug('Room closed', { room_id: this.id });
}
// #################################################### // ####################################################
// PRODUCER AUDIO LEVEL OBSERVER // PRODUCER AUDIO LEVEL OBSERVER
@@ -396,8 +403,8 @@ module.exports = class Room {
} }
} }
stopAudioLevelObserver() { closeAudioLevelObserver() {
if (this.audioLevelObserver) { if (this.audioLevelObserver && !this.audioLevelObserver.closed) {
this.audioLevelObserver.close(); this.audioLevelObserver.close();
this.audioLevelObserver = null; this.audioLevelObserver = null;
log.debug('Audio Level Observer closed'); log.debug('Audio Level Observer closed');
@@ -438,8 +445,8 @@ module.exports = class Room {
} }
} }
stopActiveSpeakerObserver() { closeActiveSpeakerObserver() {
if (this.activeSpeakerObserver) { if (this.activeSpeakerObserver && !this.activeSpeakerObserver.closed) {
this.activeSpeakerObserver.close(); this.activeSpeakerObserver.close();
this.activeSpeakerObserver = null; this.activeSpeakerObserver = null;
log.debug('Active Speaker Observer closed'); log.debug('Active Speaker Observer closed');
@@ -544,7 +551,7 @@ module.exports = class Room {
this.delPeer(peer); this.delPeer(peer);
if (this.getPeersCount() === 0) { if (this.getPeersCount() === 0) {
this.closeRouter(); this.close();
} }
} }