diff --git a/src/blocking-queue.test.ts b/src/blocking-queue.test.ts index f3a8f07..1766326 100644 --- a/src/blocking-queue.test.ts +++ b/src/blocking-queue.test.ts @@ -78,7 +78,7 @@ describe('BlockingQueue', () => { expect(await queue.dequeue()).toBe(1); expect(Date.now() - startTime).toBeLessThan(2000); expect(await queue.dequeue()).toBe(2); - expect(Date.now() - startTime).toBeGreaterThanOrEqual(2000); + expect(Math.ceil(Date.now() - startTime)).toBeGreaterThanOrEqual(2000); queue.done(); }); @@ -179,7 +179,7 @@ describe('BlockingQueue', () => { expect(await queue.dequeue()).toBe(1); const startTime = Date.now(); expect(await queue.dequeue()).toBe(2); - const duration = Date.now() - startTime; + const duration = Math.ceil(Date.now() - startTime); expect(duration).toBeGreaterThanOrEqual(2000); queue.done(); diff --git a/src/iterable-queue.test.ts b/src/iterable-queue.test.ts index f78dcce..8290e92 100644 --- a/src/iterable-queue.test.ts +++ b/src/iterable-queue.test.ts @@ -74,7 +74,7 @@ describe('IterableQueue', () => { for await (const item of queue) { expect(item).toBe(items[iteratedCount]); iteratedCount++; - expect(Date.now() - startTime).toBeGreaterThanOrEqual(2000); + expect(Math.ceil(Date.now() - startTime)).toBeGreaterThanOrEqual(2000); } expect(iteratedCount).toBe(2); @@ -159,7 +159,7 @@ describe('IterableQueue', () => { for await (const item of queue) { expect(item).toBe(items[iteratedCount]); iteratedCount++; - expect(Date.now() - startTime).toBeGreaterThanOrEqual(2000); + expect(Math.ceil(Date.now() - startTime)).toBeGreaterThanOrEqual(2000); } expect(iteratedCount).toBe(2);