如何转换两个不可观测数据流

Question

我有两个可观察的可观察的

this.loaded$.pipe(
  merge(this.loading$)
).subscribe(console.log); //`false`,`false`; `true`,`false`; etc

然后，我想根据条件将流转换为单个布尔可观测值：
如果val1 val2==1-返回false；如果val1 val2！==1-返回真；

因此，问题是如何转换合并的可观察对象？

更新1:
绑定到使用CombineTest但遇到问题：

combineLatest(
  this.loaded$, this.loading$,
  (val1, val2) => val1 + val2 === 1
);

[ts]运算符“”不能应用于类型“{}”和“boolean”。

最新动态

不存在于组合最新（）

    combineLatest(
          this.loaded$, this.loading$,
          (val1, val2) => (val1, val2) => Number(val1) + Number(val2) === 1
        ).subscribe(); // does not work

[ts]类型“OperatorFunction”上不存在属性“subscribe”

更新3:
我在这里找到了我的问题的答案，为什么'CombineTest'返回运算符函数




Answer 1

您可以使用mapXXX操作符来实现它。例如：

this.loaded$.pipe(
  merge(this.loading$),
  map((value) =>  val > 5 ? true : false)
).subscribe(console.log); //`false`,`false`; `true`,`false`; etc

Answer 2

[ts]类型“OperatorFunction”上不存在属性“subscribe”

当您试图将输出从布尔值转换为数字时，如果您想更改需要使用SwitchMap的类型，就会出现此错误，但据我所知，一次只需要一个可观察的流。

因此，建议使用下面给出的forkjoin，这也将解决您的问题。

作为其布尔结果，您应该应用逻辑运算符(

 (val1, val2) => val1 && val2 

正如您已经意识到的，您将收到两个值，即您有固定数量的请求，并且两个请求都需要完成才能获得结果，那么您应该使用forkJoin

async getResult()
{
    const example = await forkJoin( request1, request2).toPromise();
    const output = example [0] && example[1];
}

没有得到多少您想要实现的目标，但是如果您想要应用，那么您应该将布尔值转换为如下所示的数字

 (val1, val2) => Number(val1) + Number(val2);