Fix unhandled The server aborted pending request rejection

Fixes #1308

source/as-promise/core.ts

@@ -8,7 +8,12 @@ import {
 	ParseError,
 	Response
 } from './types';
-import Request, {knownHookEvents, RequestError, Method, ParseJsonFunction} from '../core';
+import Request, {
+	knownHookEvents,
+	RequestError,
+	Method,
+	ParseJsonFunction
+} from '../core';
 
 if (!knownHookEvents.includes('beforeRetry' as any)) {
 	knownHookEvents.push('beforeRetry' as any, 'afterResponse' as any);
@@ -146,6 +151,10 @@ export default class PromisableRequest extends Request {
 	}
 
 	async _beforeError(error: Error): Promise<void> {
+		if (this.destroyed) {
+			return;
+		}
+
 		if (!(error instanceof RequestError)) {
 			error = new RequestError(error.message, error, this);
 		}

source/core/index.ts

@@ -1079,7 +1079,7 @@ export default class Request extends Duplex implements RequestEvents<Request> {
 		response.once('aborted', () => {
 			this._beforeError(new ReadError({
 				name: 'Error',
-				message: 'The server aborted the pending request'
+				message: 'The server aborted pending request'
 			}, this));
 		});
 

test/http.ts

@@ -223,7 +223,7 @@ test('throws an error if the server aborted the request', withServer, async (t,
 	});
 
 	await t.throwsAsync(got(''), {
-		message: 'The server aborted the pending request'
+		message: 'The server aborted pending request'
 	});
 });
 

test/promise.ts

@@ -37,3 +37,16 @@ test('returns buffer on compressed response', withServer, async (t, server, got)
 	const {body} = await got({decompress: false});
 	t.true(Buffer.isBuffer(body));
 });
+
+test('no unhandled `The server aborted pending request` rejection', withServer, async (t, server, got) => {
+	server.get('/', (_request, response) => {
+		response.statusCode = 503;
+		response.write('asdf');
+
+		setTimeout(() => {
+			response.end();
+		}, 100);
+	});
+
+	await t.throwsAsync(got(''));
+});