feat: update handler to be protected and only handle errors once

Author: jmcdo29

packages/common/file-stream/streamable-file.ts

@@ -3,21 +3,19 @@ import { types } from 'util';
 import { isFunction } from '../utils/shared.utils';
 import { StreamableFileOptions } from './streamable-options.interface';
 
-interface StreamableHandlerResponse {
+export interface StreamableHandlerResponse {
   statusCode: number;
   send: (msg: string) => void;
 }
 
 export class StreamableFile {
   private readonly stream: Readable;
 
-  private handler: (err: Error, response: StreamableHandlerResponse) => void = (
-    err: Error,
-    res,
-  ) => {
-    res.statusCode = 400;
-    res.send(err.message);
-  };
+  protected handler: (err: Error, response: StreamableHandlerResponse) => void =
+    (err: Error, res) => {
+      res.statusCode = 400;
+      res.send(err.message);
+    };
 
   constructor(buffer: Uint8Array, options?: StreamableFileOptions);
   constructor(readable: Readable, options?: StreamableFileOptions);

packages/platform-express/adapters/express-adapter.ts

@@ -81,7 +81,7 @@ export class ExpressAdapter extends AbstractHttpAdapter {
         response.setHeader('Content-Length', streamHeaders.length);
       }
       return pipeline(
-        body.getStream().on('error', (err: Error) => {
+        body.getStream().once('error', (err: Error) => {
           body.errorHandler(err, response);
         }),
         response,