管道操作符时如何返回可观察到的`forkJoin`

Posted 2023-02-19

【中文标题】管道操作符时如何返回可观察到的`forkJoin`

【英文标题】：How to return a `forkJoin` observable when piping the operators

【发布时间】：2018-11-07 14:06:25

【问题描述】：

在我拥有这个运行良好的解析器之前：

resolve() 
    return forkJoin(
        this.getData1(),
        this.getData2(),
        this.getData3()
    );

现在我必须做一些实际上不起作用的事情：

  resolve() 
    return this.actions$
      .pipe(
        ofActionSuccessful(SomeSctonSuccess),
        forkJoin(
           this.getData1(),
           this.getData2(),
           this.getData3()
        )
      );
    

当我遇到这个错误时：

'Observable' 类型的参数不可赋值 到“OperatorFunction”类型的参数。类型 'Observable' 没有为签名提供匹配 '（来源：Observable）：Observable'。

任何想法如何解决？

现在我注意只有在ofActionSuccessful(SomeSctonSuccess) 发生https://ngxs.gitbook.io/ngxs/advanced/action-handlers 之后才返回我的forkJoin

【问题讨论】：

github.com/SrgSprinkles/AngularWeatherApp/blob/…

@Sajeetharan 感谢您指出正确的方向。但是现在在使用exhaustMap 我的组件ngOnInit 和constructore 之后停止被调用？有什么想法吗？

你能发布你的 ngOnInit 代码吗？

【参考方案1】：

使用exhaustMap 运算符。它映射到内部 observable，忽略其他值直到 observable 完成

import  forkJoin  from 'rxjs';
import  exhaustMap  from 'rxjs/operators';

resolve() 
    return this.actions$
      .pipe(
        ofActionSuccessful(SomeSctonSuccess),
        exhaustMap(() => 
         return forkJoin(
             this.getData1(),
             this.getData2(),
             this.getData3()
           )
       )

      );
    

【讨论】：

这就是评论所崇敬的内容，我通过查看相关网址得到了这一点

【参考方案2】：

感谢@Sajeetharan 通过查看此url 最终使用exhaustMap

  resolve() 
    return this.actions$.pipe(
      ofActionSuccessful(LoadOnPremHostSuccess),
      exhaustMap(() => 
        return forkJoin(
          this.getData1(),
           this.getData2(),
           this.getData3()
        );
      )
    );