diff --git a/modules/util/AsyncQueue.js b/modules/util/AsyncQueue.js index b516cef4b5..e03b1ddea6 100644 --- a/modules/util/AsyncQueue.js +++ b/modules/util/AsyncQueue.js @@ -35,7 +35,7 @@ export default class AsyncQueue { clear() { for (const finishedCallback of this._taskCallbacks.values()) { try { - finishedCallback(new ClearedQueueError('The queue has been cleared')); + finishedCallback(new ClearedQueueError('The queue has been cleared')); } catch (error) { logger.error('Error in callback while clearing the queue:', error); }