使用 combineLatest 和 Rxjs 返回 observable 的结果

Posted

技术标签:

【中文标题】使用 combineLatest 和 Rxjs 返回 observable 的结果【英文标题】:Return result of an observable with combineLatest and Rxjs 【发布时间】:2021-03-06 11:44:33 【问题描述】:

我希望得到一个 observable 的结果,每次值改变时都会减去默认值

每次值更改时,都会用输入字段中输入的新值减去默认值

例如默认值为 5。

我在输入框中输入 4

结果是 5-4 = 1 所以我希望在输入字段“Surface ha”中显示 1

我清除字段然后输入 3 结果是 5-3 = 2 所以我希望在输入字段“Surface ha”中显示 2

所以......

如果我执行 console.log,我可以清楚地看到 observable 的结果,但是我希望将 observable 的结果显示到同一个输入字段中

我只在我的开发控制台中得到这种错误结果:

NaN

观点:

   <form [formGroup]="credentialsForm" *ngIf="credentialsForm">
    <mat-form-field class="example-full-width">
        <mat-label>Surface Ha</mat-label>
        <input matInput type="number" [value]="surface" placeholder="Libellé" formControlName='surface'>
    </mat-form-field>

    <ion-input  class="form-control" placeholder="Valeur" 
                formControlName="0">
            </ion-input>
   </form>

组件内部:

    this.surface = 5;

    const observedValues = ['0']
    .map(key => this.credentialsForm.controls[key].valueChanges.map(value => +value).startWith(0))

    const resSurface = combineLatest(observedValues)
    .pipe(map(([value0]) =>  return this.surface - value0 ));
    

    const res = resSurface.subscribe(val =>  return val );

   // These line below should display the "res" value
    this.surface = res;

【问题讨论】:

【参考方案1】:

您需要将 Observable 发出的值分配给this.surface,而不是订阅本身:

resSurface.subscribe(val => this.surface = val);

或者,您可以摆脱 subscribe 调用并使用 Angular async 管道直接绑定到 Observable:

this.resSurface = combineLatest(observedValues)
                    .pipe(map(([value0, value1, value2]) =>  return this.surface - (value0 + value1 + value2) ));

然后在你的模板中:

<input matInput type="number" [value]="resSurface | async" placeholder="Libellé" formControlName='surface'>

【讨论】:

对不起,我没有解释清楚,我希望重用“res”值在表单视图上显示它 啊,我想我明白了 - 我已经编辑了我的答案。 resSurface.subscribe(val => this.surface = val);重新定义 this.surface 但我希望返回 observable 的结果,而不是将 this.surface 重新定义为 observable 本身【参考方案2】:

我忘了从不同的默认值开始!

            let defaultValueSurface = 5;

            const observedValues = ['0']
            .map(key => this.credentialsForm.controls[key].valueChanges.map(value => +value).startWith(0))

            const resSurface = combineLatest(observedValues)
            .pipe(map(([value0]) =>  return defaultValueSurface - value0 ));
            
        
            const res = resSurface.subscribe(val =>  return val );

         
            this.surface = res;

【讨论】:

以上是关于使用 combineLatest 和 Rxjs 返回 observable 的结果的主要内容,如果未能解决你的问题,请参考以下文章

在 RxJS 5.0 中找不到“combineLatest”

Rxjs:Observable.combineLatest vs Observable.forkJoin

如何提供一个Rxjs observable作为使用Jasmine中的combineLatest的方法的数据

ionic - RXJS 错误:rxjs_Observable__.Observable.combineLatest 不是函数

[RxJS] Combining Streams with CombineLatest

如何从 RxJS combineLatest 中删除瞬态事件与 NGRX 存储源 observable