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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
'use strict';
const common = require('../common');
const assert = require('assert');
const events = require('events');
const { createServer, request } = require('http');
events.captureRejections = true;
{
const server = createServer(common.mustCall((req, res) => {
const _err = new Error('kaboom');
res.on('drain', common.mustCall(async () => {
throw _err;
}));
res.socket.on('error', common.mustCall((err) => {
assert.strictEqual(err, _err);
}));
// Write until there is space in the buffer
while (res.write('hello')) {}
}));
server.listen(0, common.mustCall(() => {
const req = request({
method: 'GET',
host: server.address().host,
port: server.address().port
});
req.end();
req.on('response', common.mustCall((res) => {
res.on('aborted', common.mustCall());
res.resume();
server.close();
}));
}));
}
{
let _res;
let shouldEnd = false;
// Not using mustCall here, because it is OS-dependant.
const server = createServer((req, res) => {
// So that we cleanly stop
_res = res;
if (shouldEnd) {
res.end();
}
});
server.listen(0, common.mustCall(() => {
const _err = new Error('kaboom');
const req = request({
method: 'POST',
host: server.address().host,
port: server.address().port
});
req.on('response', common.mustNotCall((res) => {
// So that we cleanly stop
res.resume();
server.close();
}));
req.on('error', common.mustCall((err) => {
server.close();
// On some variants of Windows, this can happen before
// the server has received the request.
if (_res) {
_res.end();
} else {
shouldEnd = true;
}
assert.strictEqual(err, _err);
}));
req.on('drain', common.mustCall(async () => {
throw _err;
}));
// Write until there is space in the buffer
while (req.write('hello')) {}
}));
}
|
