http destroys socket too soon #21026

const http = require("http");
const net = require("net");
const stream = require("stream");

const PORT = 1235;

let serverReceivedRequestHeaders = false;

// create HTTP server
const server = http.createServer((request, response) => {
	serverReceivedRequestHeaders = true;
	response.writeHead(401, "test error");
	response.end();
});
server.listen(PORT, (error) => {
	if (error) {
		console.log(error);
		return;
	}

	// send request
	const request = http.request({
		hostname: 'localhost',
		method: 'POST',
		path: '/',
		port: PORT
	});
	request.once("response", (response) => {
		console.log("response", response.statusCode);
	});
	request.once("error", (error) => {
		console.log("request error", error);
	});

	// keep sending more request body until the server receives the request headers
	const requestBody = new stream.PassThrough();
	const writeMore = (cb) => {
		requestBody.write("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", (error) => {
			if (error) {
				cb(error);
			} else if (serverReceivedRequestHeaders) {
				cb();
			} else {
				writeMore(cb);
			}
		});
	}
	requestBody.pipe(request);
	writeMore(() => undefined);
});