1. 在 Angular 组件中，使用 Angular 服务向服务器发送请求，以获取最新的数据。可以使用 RxJS 从服务器流式传输数据。

import { Injectable } from '@angular/core'; import { Socket } from 'socket.io-client'; import { Observable } from 'rxjs';

@Injectable() export class DataService { constructor(private socket: Socket) {}

getData(): Observable { return new Observable(observer => { this.socket.on('data', (data: Data[]) => { observer.next(data); }); this.socket.emit('getData'); }); } }

2. 在 NestJS 控制器中，使用 Socket.IO 向客户端发送数据。可以使用 RxJS 从数据库或其他数据源流式传输数据。

import { Controller, Get, UseInterceptors } from '@nestjs/common'; import { Observable } from 'rxjs'; import { map } from 'rxjs/operators'; import { DataService } from './data.service'; import { Data } from './data';

@UseInterceptors(CacheInterceptor) @Controller() export class DataController { constructor(private readonly dataService: DataService) {}

@Get('data') getData(): Observable { return this.dataService.getData().pipe( map(data => { this.socket.emit('data', data); return data; }), ); } }

3. 现在客户端将在每次请求数据时更新数据流。您可以在 Angular 组件中订阅这个数据流，并在模板中显示数据。

@Component({ selector: 'app-data', template:

• {{ item }}

constructor(private dataService: DataService) {}

ngOnInit() { this.dataService.getData().subscribe(data => { this.items = data; }); } }