Archive/rdio-scanner
1
0
Fork 0
mirror of https://github.com/chuot/rdio-scanner.git synced 2026-08-13 16:33:01 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Better queue management

Browse source
This commit is contained in:
Chrystian Huot 2019-06-17 07:41:02 -04:00
parent ac6c1c985a
commit 575c6ec1fc
1 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
client/imports/app/radio/radio.service.ts
View file

@ -134,6 +134,10 @@ export class AppRadioService implements OnDestroy {
this._hold.system = this._hold.system === null ? call.systemData || call.system : null; this._hold.system = this._hold.system === null ? call.systemData || call.system : null;
this._emitHoldEvent(this._hold.system === null ? '-sys' : '+sys'); this._emitHoldEvent(this._hold.system === null ? '-sys' : '+sys');
if (this._hold.system !== null) {
this._cleanQueue();
}
} }
} }
@ -144,6 +148,10 @@ export class AppRadioService implements OnDestroy {
this._hold.talkgroup = this._hold.talkgroup === null ? call.talkgroupData || call.talkgroup : null; this._hold.talkgroup = this._hold.talkgroup === null ? call.talkgroupData || call.talkgroup : null;
this._emitHoldEvent(this._hold.talkgroup === null ? '-tg' : '+tg'); this._emitHoldEvent(this._hold.talkgroup === null ? '-tg' : '+tg');
if (this._hold.talkgroup !== null) {
this._cleanQueue();
}
} }
} }
@ -157,6 +165,8 @@ export class AppRadioService implements OnDestroy {
this._emitLiveEvent(); this._emitLiveEvent();
this._flushQueue(); this._flushQueue();
this.stop();
} }
this._writeLive(); this._writeLive();
@ -256,6 +266,16 @@ export class AppRadioService implements OnDestroy {
} }
} }
private _cleanQueue(): void {
const queueLength = this._call.queue.length;
this._call.queue = this._call.queue.filter((_call: RadioCall) => !this._callFiltered(_call));
if (queueLength !== this._call.queue.length) {
this._emitQueueEvent();
}
}
private _configureAudio(): void { private _configureAudio(): void {
const stopHandler = () => { const stopHandler = () => {
if (this._call.current) { if (this._call.current) {