如何在nestjs拦截器中返回takeUntil之后的其他内容

npm install rxjs

import { Observable } from 'rxjs';
import { takeUntil } from 'rxjs/operators';

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';

@Injectable()
export class MyInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const stopSignal = new Subject();

    // 在这里使用takeUntil操作符来指定终止条件
    return next.handle().pipe(takeUntil(stopSignal));
  }
}

stopSignal.next();