如何在NestJS拦截器中等待Promise完成后返回Observable？

问题根源在于Promise是异步执行的，你的return语句会在geocoder.geocode的Promise完成前同步执行，此时retour还未被赋值；而把return放进Promise回调里时，intercept方法本身没有返回值，不符合TypeScript对该方法返回Observable类型的要求，因此触发报错。

解决方案：用RxJS操作符串联Promise与Observable流 #

利用RxJS的from操作符将Promise转换为Observable，再通过switchMap、catchError等操作符串联异步逻辑与原本的请求流，既满足类型要求，又能等待Promise完成后再处理响应：

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable, from, catchError } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

@Injectable()
export class PointsInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const monaddress = context.switchToHttp().getRequest().body;

    // 将Promise转为Observable，串联异步逻辑与请求流
    return from(geocoder.geocode(monaddress)).pipe(
      switchMap(res => {
        const retour = res[0].latitude;
        // 拿到地理编码结果后，继续处理原请求流并注入retour
        return next.handle().pipe(
          map(response => ({ ...response, retour }))
        );
      }),
      catchError(err => {
        console.error(err);
        const retour = err;
        // 捕获错误后，同样处理原请求流并注入错误信息
        return next.handle().pipe(
          map(response => ({ ...response, retour }))
        );
      })
    );
  }
}

关键逻辑说明 #

• from(geocoder.geocode(monaddress))：把Promise转换为Observable，让异步逻辑能纳入RxJS的流处理体系。
• switchMap：等待Promise完成并拿到结果后，再切换到原请求的Observable流（next.handle()），确保retour已完成赋值。
• catchError：捕获Promise执行中的错误，同样注入到后续的响应流中，保证拦截器的错误处理逻辑完整。

内容的提问来源于stack exchange，提问作者Philippe Corrèges