我正在使用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';
目前测试的问题的答案
在我拥有这个运行良好的解析器之前:
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)