TypeScript - NestJS Akış Dosyaları tekniği çalışmıyor


NestJS Akışlı Dosyalar tekniğini kullanarak CSV dosyasını akış olarak göndermeye çalışıyorum, ancak istek takılmış gibi görünüyor. Burada bir şeyi mi kaçırıyorum?

Örnek kod parçası:

import {StreamableFile} from '@nestjs/common';
import * as fs from 'fs';

@Get('csv')
csvStream(
  @Req() req: Request,
  @Res() res: Response,
): StreamableFile {
  const file = 'test.csv';
  const readStream = fs.createReadStream(file);
  readStream.on('data', (chunk) => console.log(chunk));  <--- the data log gets printed
  readStream.on('finish', () => console.log('done'));
  return new StreamableFile(readStream);
}

Veri günlüğü yazdırılır (ifadeyi kontrol edin - readStream.on('data', (chunk) => console.log(chunk))), ve çıktı aşağıdakine benzer:

<Buffer 23 4a 45 67 11 97 ... 1022 more bytes>

ve istek bu durumda takılı kalıyor.

Cevap #1

Aşağıdakiler benim için yerel olarak işe yaradı...

import { Controller, Get, Req, Response, StreamableFile } from '@nestjs/common';
import * as fs from 'fs';
import * as path from 'path';

@Controller()
export class FileController {
    @Get('csv')
    csvStream(@Req() req, @Response({ passthrough: true }) res): StreamableFile {
        res.set({
            'Content-Type': 'text/plain'
        });

        const file = path.join(__dirname, 'test.csv');
        const readStream = fs.createReadStream(file);
        readStream.on('data', (chunk) => console.log(chunk)); // <--- the data log gets printed
        readStream.on('end', () => console.log('done'));
        readStream.on('error', (err) => { console.error(err); });

        return new StreamableFile(readStream);
    }
}

Lütfen { passthrough: true } öğesine dikkat edin. Bu, yanıt almamı sağladı, bu yüzden oldukça önemli görünüyor!!!

Cevap #2

{ passthrough: true } gereklidir çünkü StreamableFile özel bir nesnedir, bu yüzden bunu açıkça bir sonraki orta katmana geçirmeniz gerekir -- istemciye yanıt göndermekten sorumlu değildir.