Application hangs when destroying a `File.createWriteStream()` stream to abort the upload about nodejs-storage HOT 3 OPEN

import { join } from 'path';
import { createReadStream } from 'fs';
import { Writable, Readable } from 'stream'
import { TransformStream } from 'stream/web'

import { Storage } from '@google-cloud/storage'

const _sourcePathname = join(process.cwd(), 'test/people-2000000.csv');
const _storage = new Storage({ keyFilename: './secrets/gcp.json' });
const _bucket = _storage.bucket('journeywise_test_bucket');

const sourceFile = createReadStream(_sourcePathname, { encoding: 'utf-8' })
const _readable = Readable.toWeb(sourceFile);

const destinationFile = _bucket.file('output.csv');
const destinationStream = destinationFile.createWriteStream();
const _writable = Writable.toWeb(destinationStream);


const assertSize = (assertSize: number) => {
	let size = 0;
	return new TransformStream({
		transform(chunk, ctrl) {
			size += chunk.length;
			ctrl.enqueue(chunk);
		},
		flush() {
			console.log('Closed stream. Size match?', size == assertSize);
		}
	})
}

_readable
	.pipeThrough(assertSize(235121126))
	.pipeTo(_writable)
	.then(() => console.log('stream completed successfully'))