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

athouary · Oct 16, 2023 · a115161 · a115161
1 parent 510b646
commit a115161
Showing 1 changed file with 4 additions and 0 deletions.
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();
     }