test: adds test to check rxjs support

integration/send-files/e2e/express.spec.ts

@@ -42,4 +42,12 @@ describe('Express FileSend', () => {
       .expect(200)
       .expect({ value: 'Hello world' });
   });
+  it('should return a file from an RxJS stream', async () => {
+    return request(app.getHttpServer())
+      .get('/file/rxjs/stream/')
+      .expect(200)
+      .expect((res) => {
+        expect(res.body.toString()).to.be.eq(readmeString);
+      });
+  });
 });

integration/send-files/e2e/fastify.spec.ts

@@ -48,4 +48,12 @@ describe('Fastify FileSend', () => {
       expect(payload).to.be.eq({ value: 'Hello world' });
     });
   });
+  it('should return a file from an RxJS stream', async () => {
+    return app.inject({
+      method: 'GET',
+      url: '/file/rxjs/stream'
+    }).then(({ payload }) => {
+      expect(payload.toString()).to.be.eq(readmeString);
+    });
+  });
 });

integration/send-files/src/app.controller.ts

@@ -1,4 +1,5 @@
 import { Controller, Get, StreamableFile } from '@nestjs/common';
+import { Observable } from 'rxjs';
 import { AppService } from './app.service';
 import { NonFile } from './non-file';
 
@@ -20,4 +21,9 @@ export class AppController {
   getNonFile(): NonFile {
     return this.appService.getNonFile();
   }
+
+  @Get('file/rxjs/stream')
+  getRxJSFile(): Observable<StreamableFile> {
+    return this.appService.getRxJSFile();
+  }
 }

integration/send-files/src/app.service.ts

@@ -1,6 +1,7 @@
 import { Injectable, StreamableFile } from '@nestjs/common';
 import { createReadStream, readFileSync } from 'fs';
 import { join } from 'path';
+import { Observable, of } from 'rxjs';
 import { NonFile } from './non-file';
 
 @Injectable()
@@ -18,4 +19,8 @@ export class AppService {
   getNonFile(): NonFile {
     return new NonFile('Hello world');
   }
+
+  getRxJSFile(): Observable<StreamableFile> {
+    return of(this.getReadStream());
+  }
 }