@@ -21,8 +21,9 @@ import { randomUUID } from 'node:crypto'
21
21
import { test , describe , expect , assert } from 'vitest'
22
22
import { Writable } from 'node:stream'
23
23
import { finished , pipeline } from 'node:stream/promises'
24
+ import { setTimeout } from 'node:timers/promises'
24
25
25
- import { generateBytes , generateFixedBytes , sleep } from '../utils.mjs'
26
+ import { generateBytes , generateFixedBytes } from '../utils.mjs'
26
27
27
28
/**
28
29
* @param {import("../../index").Operator } op
@@ -108,7 +109,7 @@ export function run(op) {
108
109
const bs = await op . read ( filename , { ifModifiedSince : sinceMinus . toISOString ( ) } )
109
110
assert . equal ( Buffer . compare ( bs , content ) , 0 )
110
111
111
- await sleep ( 1000 )
112
+ await setTimeout ( 1000 )
112
113
113
114
const sinceAdd = new Date ( meta . lastModified )
114
115
sinceAdd . setSeconds ( sinceAdd . getSeconds ( ) + 1 )
@@ -133,7 +134,7 @@ export function run(op) {
133
134
'ConditionNotMatch' ,
134
135
)
135
136
136
- await sleep ( 1000 )
137
+ await setTimeout ( 1000 )
137
138
138
139
const sinceAdd = new Date ( meta . lastModified )
139
140
sinceAdd . setSeconds ( sinceAdd . getSeconds ( ) + 1 )
@@ -275,7 +276,7 @@ export function run(op) {
275
276
const buf = Buffer . concat ( chunks )
276
277
assert . equal ( Buffer . compare ( buf , content ) , 0 )
277
278
278
- await sleep ( 1000 )
279
+ await setTimeout ( 1000 )
279
280
280
281
const sinceAdd = new Date ( meta . lastModified )
281
282
sinceAdd . setSeconds ( sinceAdd . getSeconds ( ) + 1 )
@@ -301,7 +302,7 @@ export function run(op) {
301
302
const bs = Buffer . alloc ( content . length )
302
303
await expect ( r . read ( bs ) ) . rejects . toThrowError ( 'ConditionNotMatch' )
303
304
304
- await sleep ( 1000 )
305
+ await setTimeout ( 1000 )
305
306
306
307
const sinceAdd = new Date ( meta . lastModified )
307
308
sinceAdd . setSeconds ( sinceAdd . getSeconds ( ) + 1 )
0 commit comments