Attempt to skip emitting uploadProgress after destroy

Author: szmarczak

source/core/index.ts

@@ -483,7 +483,8 @@ export default class Request extends Duplex implements RequestEvents<Request> {
 					return;
 				}
 
-				if (!error) {
+				// The `!destroyed` check is required to prevent `uploadProgress` being emitted after the stream was destroyed
+				if (!error && this._request!.destroyed) {
 					this._bodySize = this._uploadedSize;
 
 					this.emit('uploadProgress', this.uploadProgress);
@@ -1178,7 +1179,8 @@ export default class Request extends Duplex implements RequestEvents<Request> {
 		}
 
 		this._request.write(chunk, encoding!, (error?: Error | null) => { // eslint-disable-line @typescript-eslint/ban-types
-			if (!error) {
+			// The `!destroyed` check is required to prevent `uploadProgress` being emitted after the stream was destroyed
+			if (!error && !this._request!.destroyed) {
 				this._uploadedSize += Buffer.byteLength(chunk, encoding);
 
 				const progress = this.uploadProgress;

test/post.ts

@@ -440,3 +440,31 @@ 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();
+});