1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
'use strict'
const { test } = require('tap')
const { fetch } = require('../..')
const { createServer } = require('http')
const { once } = require('events')
const { DOMException } = require('../../lib/fetch/constants')
/* global AbortController */
test('parallel fetch with the same AbortController works as expected', async (t) => {
const body = {
fixes: 1389,
bug: 'Ensure request is not aborted before enqueueing bytes into stream.'
}
const server = createServer((req, res) => {
res.statusCode = 200
res.end(JSON.stringify(body))
})
t.teardown(server.close.bind(server))
const abortController = new AbortController()
async function makeRequest () {
const result = await fetch(`http://localhost:${server.address().port}`, {
signal: abortController.signal
}).then(response => response.json())
abortController.abort()
return result
}
server.listen(0)
await once(server, 'listening')
const requests = Array.from({ length: 10 }, makeRequest)
const result = await Promise.allSettled(requests)
// since the requests are running parallel, any of them could resolve first.
// therefore we cannot rely on the order of the requests sent.
const { resolved, rejected } = result.reduce((a, b) => {
if (b.status === 'rejected') {
a.rejected.push(b)
} else {
a.resolved.push(b)
}
return a
}, { resolved: [], rejected: [] })
t.equal(rejected.length, 9) // out of 10 requests, only 1 should succeed
t.equal(resolved.length, 1)
t.ok(rejected.every(rej => rej.reason?.code === DOMException.ABORT_ERR))
t.same(resolved[0].value, body)
t.end()
})
|
