mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-16 22:01:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

test for headersSent

Browse Source
This commit is contained in:
Ciro Spaciari
2024-09-06 15:37:44 -07:00
parent 1ec4a5ce3e
commit 876ff4c199
1 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
test/js/node/http/node-http.test.ts
View File

@@ -2361,6 +2361,22 @@ it("should emit close when connection is aborted", async () => {
}
});
it("must set headersSent to true after headers are sent", async () => {
const server = createServer().listen(0);
try {
await once(server, "listening");
fetch(`http://localhost:${server.address().port}`).then(res => res.text());
const [req, res] = await once(server, "request");
expect(res.headersSent).toBe(false);
const { promise, resolve } = Promise.withResolvers();
res.end("OK", resolve);
await promise;
expect(res.headersSent).toBe(true);
} finally {
server.close();
}
});
it("should emit timeout event", async () => {
const server = http.createServer().listen(0);
try {
@@ -2403,3 +2419,22 @@ it("should emit timeout event when using server.setTimeout", async () => {
server.closeAllConnections();
}
}, 12_000);
it("must set headersSent to true after headers are sent when using chunk encoded", async () => {
const server = createServer().listen(0);
try {
await once(server, "listening");
fetch(`http://localhost:${server.address().port}`).then(res => res.text());
const [req, res] = await once(server, "request");
expect(res.headersSent).toBe(false);
const { promise, resolve } = Promise.withResolvers();
res.write("first", () => {
res.write("second", () => {
res.end("OK", resolve);
});
});
await promise;
expect(res.headersSent).toBe(true);
} finally {
server.close();
}
});