Stop File stream if file is too large

Hey guys! I'm trying to do some file upload with trpc and I took the example from here: https://github.com/trpc/trpc/blob/main/examples/minimal-content-types/server/index.ts

file: publicProcedure.input(octetInputParser).mutation(async ({ input }) => {
    const chunks = [];
    const FILE_SIZE_LIMIT = 10 * 1024 * 1024; // 10 MB
    const reader = input.getReader();
    while (true) {
      const { done, value } = await reader.read();
      if (done) {
        break;
      }
      const size = Buffer.byteLength(value);

      chunks.push(value);
      fileSize += size;
      if(fileSize > FILE_SIZE_LIMIT){
        await reader.cancel('too large');
        throw new TRPCError({
          code: 'PAYLOAD_TOO_LARGE'
        }); 
      }
    }

    const content = Buffer.concat(chunks).toString('utf-8');

    console.log('File: ', content);

    return {
      text: 'ACK',
      data: content,
    };
  }),

file: publicProcedure.input(octetInputParser).mutation(async ({ input }) => {
    const chunks = [];
    const FILE_SIZE_LIMIT = 10 * 1024 * 1024; // 10 MB
    const reader = input.getReader();
    while (true) {
      const { done, value } = await reader.read();
      if (done) {
        break;
      }
      const size = Buffer.byteLength(value);

      chunks.push(value);
      fileSize += size;
      if(fileSize > FILE_SIZE_LIMIT){
        await reader.cancel('too large');
        throw new TRPCError({
          code: 'PAYLOAD_TOO_LARGE'
        }); 
      }
    }

    const content = Buffer.concat(chunks).toString('utf-8');

    console.log('File: ', content);

    return {
      text: 'ACK',
      data: content,
    };
  }),

file: publicProcedure.input(octetInputParser).mutation(async ({ input }) => {
    const chunks = [];
    const FILE_SIZE_LIMIT = 10 * 1024 * 1024; // 10 MB
    const reader = input.getReader();
    while (true) {
      const { done, value } = await reader.read();
      if (done) {
        break;
      }
      const size = Buffer.byteLength(value);

      chunks.push(value);
      fileSize += size;
      if(fileSize > FILE_SIZE_LIMIT){
        await reader.cancel('too large');
        throw new TRPCError({
          code: 'PAYLOAD_TOO_LARGE'
        }); 
      }
    }

    const content = Buffer.concat(chunks).toString('utf-8');

    console.log('File: ', content);

    return {
      text: 'ACK',
      data: content,
    };
  }),

file: publicProcedure.input(octetInputParser).mutation(async ({ input }) => {
    const chunks = [];
    const FILE_SIZE_LIMIT = 10 * 1024 * 1024; // 10 MB
    const reader = input.getReader();
    while (true) {
      const { done, value } = await reader.read();
      if (done) {
        break;
      }
      const size = Buffer.byteLength(value);

      chunks.push(value);
      fileSize += size;
      if(fileSize > FILE_SIZE_LIMIT){
        await reader.cancel('too large');
        throw new TRPCError({
          code: 'PAYLOAD_TOO_LARGE'
        }); 
      }
    }

    const content = Buffer.concat(chunks).toString('utf-8');

    console.log('File: ', content);

    return {
      text: 'ACK',
      data: content,
    };
  }),

In the console i can see if the file is too big: