fix(AsyncQueue): call the callback only if it's a function (#2370)

jitsi · Dec 5, 2023 · d9c708d · d9c708d
1 parent 7841a38
commit d9c708d
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/modules/util/AsyncQueue.js b/modules/util/AsyncQueue.js
@@ -34,10 +34,12 @@ 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);
+            if (typeof finishedCallback === 'function') {
+                try {
+                    finishedCallback(new ClearedQueueError('The queue has been cleared'));
+                } catch (error) {
+                    logger.error('Error in callback while clearing the queue:', error);
+                }
             }
         }
         this._queue.kill();