RxJS / Angular：在订阅之前捕获FormControl的valueChanges

如何解决RxJS / Angular：在订阅之前捕获FormControl的valueChanges

我尝试根据FormControls.valueChanges观测值发出的值创建一个观测值。 可观察者是通过ngOnInit方法创建的，如下所示：

  ngOnInit(): void {
    this.myObservable$ = combineLatest([
      this.formControl1.valueChanges,this.formControl2.valueChanges
    ]).pipe(
      map(([v1,v2]) => parseInt(v1,10) + parseInt(v2,10))
    );

    this.isLoading = true;

    this.loadData().subscribe({
      next: result => {
        this.formControl1.setValue(result[0]);
        this.formControl2.setValue(result[1]);
        this.isLoading = false;
      },});
  }

将isLoading设置为false后，可观察对象得到订阅：

<div *ngIf="!isLoading">{{ myObservable$ | async }}</div>

因此，在这种情况下，myObservable$仅在手动更改formControl1和formControl2之后才开始发射值，因为valueChanges的第一个发射发生在预订此可观察对象之前。

您可以为此编写一个非常详细的解决方案：

this.myObservable$ = defer(() => combineLatest([
   this.formControl1.valueChanges.pipe(startWith(this.formControl1.value)),this.formControl2.valueChanges.pipe(startWith(this.formControl2.value))
])).pipe(
   map(([v1,10))
);

也许有更漂亮的解决方案吗？

（{https://angular-ivy-n1gwvk.stackblitz.io是最小示例的StackBlitz）

解决方法

您可以在模板中执行以下操作。也很冗长，但这是另一种方式。否则startWith是解决此问题的适当方法：

<ng-container *ngIf="{ value: (myObservable$ | async) } as my">
  <div *ngIf="!isLoading">{{ my.value }}</div>
</ng-container>

---

另一种方法是订阅它并使用shareReplay：

isLoading: true;

readonly destroy$ = new Subject<void>();

ngOnInit(): void {
  this.myObservable$ = combineLatest([
    this.formControl1.valueChanges,this.formControl2.valueChanges
  ]).pipe(
    map(([v1,v2]) => parseInt(v1,10) + parseInt(v2,10)),shareReplay(1),takeUntil(this.destroy$)
  );

  this.myObservable$.subscribe();

  this.loadData().subscribe({
    next: result => {
      this.formControl1.setValue(result[0]);
      this.formControl2.setValue(result[1]);
      this.isLoading = false;
    },});
}

ngOnDestroy(): void {
  this.destroy$.next();
  this.destroy$.complete();
}

,

我能想到的唯一方法是提取一些辅助砂，然后尝试重复一些操作。

// Helpers

const getControlValueStream = (({ control,valueChanges }): FormControl) => valueChanges.pipe(startWith(value));

const sumNumbers = (numbers: number[]) => numbers.reduce((a,b) => a + b,0);

// Component

const controls = [this.formControl1,this.formControl2];
const valueStreams = controls.map(getControlValueStream);

combineLatest(...valueStreams).pipe(
  map(values => values.map(value => parseInt(value,10))),map(sumNumbers),);

您或您的团队可能会发现它的可读性较差，这很公平-美感应与可维护性保持平衡。