小编Abr*_*kad的帖子

为什么`combineLatest`返回OperatorFunction <{},number>

我正在使用rxjs 6我的代码中有两个observable

import { combineLatest } from 'rxjs/operators';

loading$: Observable<boolean>;
loaded$: Observable<boolean>;
Run Code Online (Sandbox Code Playgroud)

可观测量不是来自http请求,而是来自store

我需要在合并/转换序列基于这个逻辑一个单一可观察值:
如果序列true,true或者false,false-需要返回新观察到的true,否则需要返回false

我试图用它combineLatest来实现:

combineLatest(
    this.loaded$, this.loading$,
    (val1, val2) => Number(val1) + Number(val2) === 1
)
Run Code Online (Sandbox Code Playgroud)

但问题是我的combineLatest回报'OperatorFunction<>而不是Observable<>我不能订阅.你有任何想法如何解决这个问题?或者,如果有另一种方法可以采取?

更新:
似乎这是我import { combineLatest } from 'rxjs';
目前测试的问题的答案

rxjs angular

6
推荐指数
1
解决办法
1259
查看次数

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

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

resolve() {
    return forkJoin(
        this.getData1(),
        this.getData2(),
        this.getData3()
    );
}
Run Code Online (Sandbox Code Playgroud)

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

  resolve() {
    return this.actions$
      .pipe(
        ofActionSuccessful(SomeSctonSuccess),
        forkJoin(
           this.getData1(),
           this.getData2(),
           this.getData3()
        )
      );
    }
Run Code Online (Sandbox Code Playgroud)

因为我遇到了这个错误:

“Observable<[any, any, any, any]>”类型的参数不可分配给“OperatorFunction”类型的参数。类型 'Observable<[any, any, any, any]>' 不匹配签名 '(source: Observable): Observable'。

任何想法如何解决?

现在我注意在发生forkJoin后返回我的唯一https://ngxs.gitbook.io/ngxs/advanced/action-handlersofActionSuccessful(SomeSctonSuccess)

rxjs angular ngxs

5
推荐指数
1
解决办法
8692
查看次数

标签 统计

angular ×2

rxjs ×2

ngxs ×1