fix(AsyncQueue): catch and log callback errors (jitsi#2370)

athouary · athouary · commit a1151618eb2b · 2023-10-16T08:58:37.000+02:00
diff --git a/modules/util/AsyncQueue.js b/modules/util/AsyncQueue.js
@@ -34,7 +34,11 @@ export default class AsyncQueue {
      */
     clear() {
         for (const finishedCallback of this._taskCallbacks.values()) {
+            try {
             finishedCallback(new ClearedQueueError('The queue has been cleared'));
+            } catch (error) {
+                logger.error('Error in callback while clearing the queue:', error);
+            }
         }
         this._queue.kill();
     }

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,11 @@ export default class AsyncQueue {`
`34`	`34`	`*/`
`35`	`35`	`clear() {`
`36`	`36`	`for (const finishedCallback of this._taskCallbacks.values()) {`
	`37`	`+ try {`
`37`	`38`	`finishedCallback(new ClearedQueueError('The queue has been cleared'));`
	`39`	`+ } catch (error) {`
	`40`	`+ logger.error('Error in callback while clearing the queue:', error);`
	`41`	`+ }`
`38`	`42`	`}`
`39`	`43`	`this._queue.kill();`
`40`	`44`	`}`