Leave uploadProgress so it gets emitted on stream end

source/core/index.ts

@@ -484,7 +484,7 @@ export default class Request extends Duplex implements RequestEvents<Request> {
 				}
 
 				// The `!destroyed` check is required to prevent `uploadProgress` being emitted after the stream was destroyed
-				if (!error && this._request!.destroyed) {
+				if (!error) {
 					this._bodySize = this._uploadedSize;
 
 					this.emit('uploadProgress', this.uploadProgress);

test/post.ts

@@ -440,31 +440,3 @@ test('formdata retry', withServer, async (t, server, got) => {
 		message: 'Cannot retry with consumed body stream',
 	});
 });
-
-test('does not emit uploadProgress after cancelation', withServer, async (t, server, got) => {
-	server.post('/', () => {});
-
-	const stream = got.stream.post();
-
-	stream.once('uploadProgress', () => { // 0%
-		stream.once('uploadProgress', () => { // 'foo'
-			stream.write('bar');
-
-			process.nextTick(() => {
-				process.nextTick(() => {
-					stream.on('uploadProgress', () => {
-						t.fail('Emitted uploadProgress after cancelation');
-					});
-
-					stream.destroy();
-				});
-			});
-		});
-	});
-
-	stream.write('foo');
-
-	await pEvent(stream, 'close');
-
-	t.pass();
-});

test/progress.ts

@@ -1,3 +1,4 @@
+import process from 'process';
 import {Buffer} from 'buffer';
 import {promisify} from 'util';
 import stream from 'stream';
@@ -11,6 +12,7 @@ import {temporaryFile} from 'tempy';
 import is from '@sindresorhus/is';
 import test, {type ExecutionContext} from 'ava';
 import type {Handler} from 'express';
+import {pEvent} from 'p-event';
 import type {Progress} from '../source/index.js';
 import withServer from './helpers/with-server.js';
 
@@ -262,3 +264,31 @@ test('upload progress - one event when removed listener', withServer, async (t,
 		},
 	]);
 });
+
+test('does not emit uploadProgress after cancelation', withServer, async (t, server, got) => {
+	server.post('/', () => {});
+
+	const stream = got.stream.post();
+
+	stream.once('uploadProgress', () => { // 0%
+		stream.once('uploadProgress', () => { // 'foo'
+			stream.write('bar');
+
+			process.nextTick(() => {
+				process.nextTick(() => {
+					stream.on('uploadProgress', () => {
+						t.fail('Emitted uploadProgress after cancelation');
+					});
+
+					stream.destroy();
+				});
+			});
+		});
+	});
+
+	stream.write('foo');
+
+	await pEvent(stream, 'close');
+
+	t.pass();
+});