@@ -89,8 +89,9 @@ describe('IterableQueueMapper', () => {
89
89
expect ( loopCount ) . toBe ( max ) ;
90
90
expect ( lastTotal ) . toBe ( max ) ;
91
91
// Should require at least 4 batches
92
+ const duration = Date . now ( ) - startTime ;
92
93
expect ( Date . now ( ) - startTime ) . toBeLessThan ( 5 * delayBetweenMs ) ;
93
- expect ( Date . now ( ) - startTime ) . toBeGreaterThan ( 4 * delayBetweenMs ) ;
94
+ expect ( Math . ceil ( duration ) ) . toBeGreaterThan ( 4 * delayBetweenMs ) ;
94
95
} ) ;
95
96
96
97
it ( 'right number run in parallel - complex' , async ( ) => {
@@ -108,7 +109,7 @@ describe('IterableQueueMapper', () => {
108
109
// Next one added should have had to wait for at least one wait period
109
110
void ( async ( ) => {
110
111
await prefetcher . enqueue ( { value : 5 , ms : delayBetweenMs } ) ;
111
- expect ( Date . now ( ) - startTime ) . toBeGreaterThanOrEqual ( delayBetweenMs ) ;
112
+ expect ( Math . ceil ( Date . now ( ) - startTime ) ) . toBeGreaterThanOrEqual ( delayBetweenMs ) ;
112
113
prefetcher . done ( ) ;
113
114
} ) ( ) ;
114
115
@@ -125,8 +126,9 @@ describe('IterableQueueMapper', () => {
125
126
expect ( lastSeen ) . toBe ( 5 ) ;
126
127
127
128
// Should require at least 2 batches
128
- expect ( Date . now ( ) - startTime ) . toBeLessThan ( 2.5 * delayBetweenMs ) ;
129
- expect ( Date . now ( ) - startTime ) . toBeGreaterThan ( 2 * delayBetweenMs ) ;
129
+ const duration = Date . now ( ) - startTime ;
130
+ expect ( duration ) . toBeLessThan ( 2.5 * delayBetweenMs ) ;
131
+ expect ( Math . ceil ( duration ) ) . toBeGreaterThan ( 2 * delayBetweenMs ) ;
130
132
} ) ;
131
133
} ) ;
132
134
} ) ;
0 commit comments