summaryrefslogtreecommitdiffstats
path: root/test/inflight-and-close.js
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
commit0b6210cd37b68b94252cb798598b12974a20e1c1 (patch)
treee371686554a877842d95aa94f100bee552ff2a8e /test/inflight-and-close.js
parentInitial commit. (diff)
downloadnode-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.tar.xz
node-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.zip
Adding upstream version 5.28.2+dfsg1+~cs23.11.12.3.upstream/5.28.2+dfsg1+_cs23.11.12.3upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'test/inflight-and-close.js')
-rw-r--r--test/inflight-and-close.js31
1 files changed, 31 insertions, 0 deletions
diff --git a/test/inflight-and-close.js b/test/inflight-and-close.js
new file mode 100644
index 0000000..49fbb10
--- /dev/null
+++ b/test/inflight-and-close.js
@@ -0,0 +1,31 @@
+'use strict'
+
+const t = require('tap')
+const { request } = require('..')
+const http = require('http')
+
+const server = http.createServer((req, res) => {
+ res.writeHead(200)
+ res.end('Response body')
+ res.socket.end() // Close the connection immediately with every response
+}).listen(0, '127.0.0.1', function () {
+ const url = `http://127.0.0.1:${this.address().port}`
+ request(url)
+ .then(({ statusCode, headers, body }) => {
+ t.pass('first response')
+ body.resume()
+ body.on('close', function () {
+ t.pass('first body closed')
+ })
+ return request(url)
+ .then(({ statusCode, headers, body }) => {
+ t.pass('second response')
+ body.resume()
+ body.on('close', function () {
+ server.close()
+ })
+ })
+ }).catch((err) => {
+ t.error(err)
+ })
+})