使用
import { Controller, Get, Res, Sse, UseGuards } from '@nestjs/common';
import { AppService } from './app.service';
import { interval, map } from 'rxjs';
import { createReadStream } from 'fs';
@Controller()
export class AppController {
constructor(private readonly appService: AppService) { }
@Get()
index(@Res() res: any) {
createReadStream("src/views/index.html").pipe(res);
}
@Sse('sse')
sse() {
return interval(50).pipe(map(() => ({ data: { hello: 'abcba' } })));
}
}
原创...小于 1 分钟