mirror of
https://github.com/denoland/deno.git
synced 2024-11-21 15:04:11 -05:00
test(ext/node): reduce http_test flakiness (#24742)
This commit is contained in:
parent
086fa28348
commit
99e811f5eb
1 changed files with 7 additions and 4 deletions
|
@ -1325,9 +1325,10 @@ Deno.test("[node/http] http.request() post streaming body works", async () => {
|
|||
}
|
||||
});
|
||||
|
||||
const deferred = Promise.withResolvers<void>();
|
||||
const responseEnded = Promise.withResolvers<void>();
|
||||
const fileClosed = Promise.withResolvers<void>();
|
||||
const timeout = setTimeout(() => {
|
||||
deferred.reject(new Error("timeout"));
|
||||
responseEnded.reject(new Error("timeout"));
|
||||
}, 5000);
|
||||
server.listen(0, () => {
|
||||
// deno-lint-ignore no-explicit-any
|
||||
|
@ -1359,7 +1360,7 @@ Deno.test("[node/http] http.request() post streaming body works", async () => {
|
|||
const response = JSON.parse(responseBody);
|
||||
assertEquals(res.statusCode, 200);
|
||||
assertEquals(response.bytes, contentLength);
|
||||
deferred.resolve();
|
||||
responseEnded.resolve();
|
||||
});
|
||||
});
|
||||
|
||||
|
@ -1369,8 +1370,10 @@ Deno.test("[node/http] http.request() post streaming body works", async () => {
|
|||
|
||||
const readStream = fs.createReadStream(filePath);
|
||||
readStream.pipe(req);
|
||||
readStream.on("close", fileClosed.resolve);
|
||||
});
|
||||
await deferred.promise;
|
||||
await responseEnded.promise;
|
||||
await fileClosed.promise;
|
||||
assertEquals(server.listening, true);
|
||||
server.close();
|
||||
clearTimeout(timeout);
|
||||
|
|
Loading…
Reference in a new issue