大家好，提前感谢您的时间。

显然，在没有意识到的情况下，我肯定在 Angular 库中更新了某些内容，因为代码已停止工作，现在我面临以下错误：

core.js:1673 ERROR TypeError： 无法读取未定义的属性（读取“subscribe”） at SafeSubscriber._next (informes.component.ts:166:77) at push../node_modules/rxjs/_esm5/internal/Subscriber.js.SafeSubscriber.__tryOrUnsub (Subscriber.js:195:1) at push../node_modules/rxjs/_esm5/internal/Subscriber.js.SafeSubscriber.next (Subscriber.js:133:1) at推送../node_modules/rxjs/_esm5/internal/Subscriber.js.Subscriber._next (Subscriber.js:77:1) 在推送../node_modules/rxjs/_esm5/internal/Subscriber.js.Subscriber.next (Subscriber.js:54:1) 在推送../node_modules/rxjs/_esm5/internal/BehaviorSubject.js.BehaviorSubject._subscribe (BehaviorSubject.js:22:1) 在推送../node_modules/rxjs/_esm5/internal/Observable.js.Observable._trySubscribe (Observable.js:42:1) 在推送../node_modules/rxjs/_esm5/internal/Subject.js.Subject._trySubscribe (Subject.js:89:1) at push../node_modules/rxjs/_esm5/internal/Observable.js.Observable.subscribe (Observable.js:28:1) at push../src/app/informes/informes.component.ts.Informes.ngOnInit (informes.component.ts:164:31)**`

它恰好出现在代码中的这一点：

ngOnInit(): void {
 
 this.rutaActiva.queryParams.subscribe(param => {
 this.inicializarParametrosRecibidos(param);
 
 this.informesService.getInformes(this.rutaActiva.snapshot.queryParams).subscribe(result => { ...

完整的函数是这样的：

ngOnInit(): void {
  this.rutaActiva.queryParams.subscribe(param => {
      this.informesService.getInformes(this.rutaActiva.snapshot.queryParams).subscribe(result => {

        if (param.busPorTipoDeInforme.toString() == "notificacion"){
          this.contratosFiltrados = result;
        }else{
          const fileURL = URL.createObjectURL(result);
          window.open(fileURL, '_black');
        }

      }
        , error => {
          console.error('Error llamando a getInformes():', error);
        },
        () => {
          console.log('La ejecución de getInformes() terminó correctamente.');
        }
        )
    });

它调用的函数是这样的：

public getInformes(filtro: any): Observable<any> {
      let params = new HttpParams();
      for(let parametro in filtro) {
          params.set(parametro, filtro[parametro]);
      }
      
      let opciones = new RequestOptions({
          search: params
      });
        
      let sUrl : string = environment.urlAplicacion + CONS_ACCIONES_SERVICIOS.ACCION_SERVICE_GET_INFORMES_NOTIF_VTOS;


      if (bBusXNotifDeVtos){
        return this.http.get(sUrl, {params: params}).pipe(map((response)  => {
          return response;
              }),catchError(error => this.tratarError(error))
        );
      }else{
        return this.http.get(sUrl, {params: params, responseType: 'blob' as 'blob'}).pipe(map(
          (response) => {
          return new Blob([response], { type: 'application/pdf' })
              }),catchError(error => this.tratarError(error))
        );
      }
    }
 }

也就是说，我定义了一个可观察函数，该函数根据参数返回 PDF 或其他对象。但是由于开头提到的错误，现在新版本对我来说不起作用。

如果我尝试以以下方式调整函数：

crearObservableGetInformes(filtro: any): Observable<Object> {
    return new Observable<Object>((observer) => {
      let params = new HttpParams();
      for(let parametro in filtro) {
          params.set(parametro, filtro[parametro]);
      }
      
      let opciones = new RequestOptions({
          search: params
      });
        
      let sUrl : string = environment.urlAplicacion + CONS_ACCIONES_SERVICIOS.ACCION_SERVICE_GET_INFORMES_NOTIF_VTOS;


      if (bBusXNotifDeVtos){
        return this.http.get(sUrl, {params: params}).pipe(map((response)  => {
          return response;
              }),catchError(error => this.tratarError(error))
        );
      }else{
        return this.http.get(sUrl, {params: params, responseType: 'blob' as 'blob'}).pipe(map(
          (response) => {
          return new Blob([response], { type: 'application/pdf' })
              }),catchError(error => this.tratarError(error))
        );
      }
    }
 }

我在以下代码中收到错误，我以粗体显示：

return new Observable( (observer) => {

这是错误描述：

Argument of type '(this: Observable<Object>, observer: Subscriber<Object>) => Observable<Object>' is not assignable to parameter of type '(this: Observable<Object>, subscriber: Subscriber<Object>) => TeardownLogic'.
  Type 'Observable<Object>' is not assignable to type 'TeardownLogic'.
    Property 'unsubscribe' is missing in type 'Observable<Object>' but required in type 'Unsubscribable'.ts(2345)

简而言之，我发现自己拥有的代码很高效，但我无法使用，也无法找到纠正方法。有人可以帮帮我吗？ 非常感谢