diff --git a/src/util/__tests__/ConcurrentQueue.test.ts b/src/util/__tests__/ConcurrentQueue.test.ts index 67db525..5074953 100644 --- a/src/util/__tests__/ConcurrentQueue.test.ts +++ b/src/util/__tests__/ConcurrentQueue.test.ts @@ -3,7 +3,7 @@ import { nextTickAsync } from '../nextTick'; class SimpleQueue extends ConcurrentQueue { handler(_item: T): Promise { - throw new Error('Method not overriden'); + throw new Error('Method not overridden'); } } @@ -39,7 +39,7 @@ test('should be able to process the queue within limit', async () => { await promises[i]; } - // Wait till all fullfilled + // Wait till all fulfilled while (queuedResolver.length !== 5) { await nextTickAsync(); } @@ -85,13 +85,13 @@ test('it should move on to the next item in the queue once failed', async () => promises.push(queue.add(4)); promises.push(queue.add(5)); - // Let first 2 be fullfilled + // Let first 2 be fulfilled for (let i = 0; i < 2; i++) { queuedResolver[i](); await promises[i]; } - // Wait till all fullfilled + // Wait till all fulfilled while (queuedResolver.length !== 4) { await nextTickAsync(); }